正文

Dubbo的擴(kuò)展點加載從JDK標(biāo)準(zhǔn)的SPI(Service Provider Interface)擴(kuò)展點發(fā)現(xiàn)機(jī)制加強(qiáng)而來。Dubbo改進(jìn)了JDK標(biāo)準(zhǔn)的SPI的以下問題：

• JDK標(biāo)準(zhǔn)的SPI會一次性實例化擴(kuò)展點所有實現(xiàn)，如果有擴(kuò)展實現(xiàn)初始化很耗時，但如果沒用上也加載，會很浪費資源。如果擴(kuò)展點加載失敗，連擴(kuò)展點的名稱都拿不到了。
• Dubbo增加了對擴(kuò)展點IoC和AOP的支持，一個擴(kuò)展點可以直接setter注入其它擴(kuò)展點。 比如：Filter是Dubbo的集合類擴(kuò)展點的一種，還有其他如InvokerListener, ExportListener, TelnetHandler, StatusChecker等擴(kuò)展，這個有時間可以都看看（搜索Dubbo開發(fā)者指南：SPI參考手冊)

擴(kuò)展點配置：

src\
 |-main\
    |-java\
        |-com\
            |-xxx\
                |-XxxFilter.java (實現(xiàn)Filter接口)\
    |-resources\
        |-META-INF\
            |-dubbo\
                |-com.alibaba.dubbo.rpc.Filter (純文本文件，內(nèi)容為：xxx=com.xxx.XxxFilter)

擴(kuò)展實現(xiàn)類：

@Activate
public class AuthorityFilter implements Filter {
    private static Logger logger = LoggerFactory.getLogger(AuthorityFilter.class);
    List<String> ipWhiteList = AuthorityUtils.getAccessListByKey("1");
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        [logger.info](http://logger.info/)("########go into filtersuccess !!########");
        String clientIp = RpcContext.getContext().getRemoteHost();
        String host = IpParseUtils.getHostByIp(clientIp);
        if (ipWhiteList.contains(host))
Unknown macro: {            [logger.info](http://logger.info/)("########白名單校驗通過！########");            return invoker.invoke(invocation);        }
else
Unknown macro: {            [logger.info](http://logger.info/)("########白名單校驗未通過！########");            return new RpcResult();        }
    }
}

攔截配置文件：

在擴(kuò)展類的jar包內(nèi)，放置擴(kuò)展點配置文件：META-INF/dubbo/接口全限定名，內(nèi)容為：配置名=擴(kuò)展實現(xiàn)類全限定名，多個實現(xiàn)類用換行符分隔。(注意：這里的配置文件是放在你自己的jar包內(nèi)，不是dubbo本身的jar包內(nèi)，Dubbo會全ClassPath掃描所有jar包內(nèi)同名的這個文件，然后進(jìn)行合并)

注意這個xxx＝左側(cè)的名字跟你擴(kuò)展類同名哦(這是個坑兒，別問我怎么知道的)！

AuthorityFilter=your.extend.dubbo.async.provider.AuthorityFilter

調(diào)用攔截擴(kuò)展:

<dubbo:provider filter="AuthorityFilter"></dubbo:provider>

攔截擴(kuò)展說明：

服務(wù)提供方和服務(wù)消費方調(diào)用過程攔截，Dubbo本身的大多功能均基于此擴(kuò)展點實現(xiàn)，每次遠(yuǎn)程方法執(zhí)行，該攔截都會被執(zhí)行，請注意對性能的影響。\

常用約定：

• 用戶自定義filter默認(rèn)在內(nèi)置filter之后。
• 特殊值default，表示缺省擴(kuò)展點插入的位置。 比如：filter="xxx,default,yyy"，表示xxx在缺省filter之前，yyy在缺省filter之后。\
• 特殊符號-，表示剔除。
  比如：filter="-foo1"，剔除添加缺省擴(kuò)展點foo1。
  比如：filter="-default"，剔除添加所有缺省擴(kuò)展點。\
• provider和service同時配置的filter時，累加所有filter，而不是覆蓋。
  比如：<dubbo:provider filter="xxx,yyy"/>和<dubbo:service filter="aaa,bbb" />，則xxx,yyy,aaa,bbb均會生效。
  如果要覆蓋，需配置：<dubbo:service filter="-xxx,-yyy,aaa,bbb" />\

實現(xiàn)細(xì)節(jié)：

• 解析服務(wù)

基于dubbo.jar內(nèi)的META-INF/spring.handlers配置，Spring在遇到dubbo名稱空間時，會回調(diào)DubboNamespaceHandler。

所有dubbo的標(biāo)簽，都統(tǒng)一用DubboBeanDefinitionParser進(jìn)行解析，基于一對一屬性映射，將XML標(biāo)簽解析為Bean對象。

在ServiceConfig.export()或ReferenceConfig.get()初始化時，將Bean對象轉(zhuǎn)換URL格式，所有Bean屬性轉(zhuǎn)成URL的參數(shù)。

然后將URL傳給Protocol擴(kuò)展點，基于擴(kuò)展點的Adaptive機(jī)制，根據(jù)URL的協(xié)議頭，進(jìn)行不同協(xié)議的服務(wù)暴露或引用。

• 攔截服務(wù)

基于擴(kuò)展點的Wrapper機(jī)制，所有的Protocol擴(kuò)展點都會自動套上Wrapper類。

基于ProtocolFilterWrapper類，將所有Filter組裝成鏈，在鏈的最后一節(jié)調(diào)用真實的引用。

基于ProtocolListenerWrapper類，將所有InvokerListener和ExporterListener組裝集合，在暴露和引用前后，進(jìn)行回調(diào)。

包括監(jiān)控在內(nèi)，所有附加功能，全部通過Filter攔截實現(xiàn)。

還有暴露服務(wù)和引用服務(wù)，個人覺得看這上面這兩個對寫程序相對更有用些！

擴(kuò)展點的幾個特點：

擴(kuò)展點自動包裝

自動Wrap擴(kuò)展點的Wrapper類

ExtensionLoader會把加載擴(kuò)展點時（通過擴(kuò)展點配置文件中內(nèi)容），如果該實現(xiàn)有拷貝構(gòu)造函數(shù)，則判定為擴(kuò)展點Wrapper類。Wrapper類同樣實現(xiàn)了擴(kuò)展點接口。

擴(kuò)展點自動裝配

加載擴(kuò)展點時，自動注入依賴的擴(kuò)展點

加載擴(kuò)展點時，擴(kuò)展點實現(xiàn)類的成員如果為其它擴(kuò)展點類型，ExtensionLoader在會自動注入依賴的擴(kuò)展點。

ExtensionLoader通過掃描擴(kuò)展點實現(xiàn)類的所有set方法來判定其成員。即ExtensionLoader會執(zhí)行擴(kuò)展點的拼裝操作。

ExtensionLoader加載CarMaker的擴(kuò)展點實現(xiàn)RaceCar時，setWheelMaker方法的WheelMaker也是擴(kuò)展點則會注入WheelMaker的實現(xiàn)。

擴(kuò)展點自適應(yīng)

擴(kuò)展點的Adaptive實例
ExtensionLoader注入的依賴擴(kuò)展點是一個Adaptive實例，直到擴(kuò)展點方法執(zhí)行時才決定調(diào)用是一個擴(kuò)展點實現(xiàn)。

• Dubbo使用URL對象（包含了Key-Value）傳遞配置信息

擴(kuò)展點方法調(diào)用會有URL參數(shù)（或是參數(shù)有URL成員）

這樣依賴的擴(kuò)展點也可以從URL拿到配置信息，所有的擴(kuò)展點自己定好配置的Key后，配置信息從URL上從最外層傳入。URL在配置傳遞上即是一條總線。

示例：有兩個為擴(kuò)展點CarMaker（造車者）、wheelMaker(造輪者)

擴(kuò)展點自動激活

對于集合類擴(kuò)展點，比如：Filter, InvokerListener, ExportListener, TelnetHandler, StatusChecker等，可以同時加載多個實現(xiàn)，此時，可以用自動激活來簡化配置，如：

import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.Filter;
@Activate // 無條件自動激活
public class XxxFilter implements Filter {
    // ...
}

以上就是Dubbo擴(kuò)展點SPI實踐示例解析的詳細(xì)內(nèi)容，更多關(guān)于Dubbo擴(kuò)展點SPI實踐的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論