溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Dubbo Provider Filter鏈?zhǔn)窃趺礃?gòu)建的

發(fā)布時(shí)間:2021-12-15 14:54:33 來源:億速云 閱讀:130 作者:iii 欄目:大數(shù)據(jù)

這篇文章主要介紹“Dubbo Provider Filter鏈?zhǔn)窃趺礃?gòu)建的”,在日常操作中,相信很多人在Dubbo Provider Filter鏈?zhǔn)窃趺礃?gòu)建的問題上存在疑惑,小編查閱了各式資料,整理出簡(jiǎn)單好用的操作方法,希望對(duì)大家解答”Dubbo Provider Filter鏈?zhǔn)窃趺礃?gòu)建的”的疑惑有所幫助!接下來,請(qǐng)跟著小編一起來學(xué)習(xí)吧!

provider端的Filter鏈構(gòu)建是在初始化流程中構(gòu)建的,我們知道初始化流程肯定會(huì)走到方法org.apache.dubbo.remoting.transport.netty4.NettyServer#doOpen中,可以在該方法打個(gè)斷點(diǎn),然后啟動(dòng)provider服務(wù),調(diào)用棧信息如下:

Dubbo Provider Filter鏈?zhǔn)窃趺礃?gòu)建的

從調(diào)用棧中方法 org.apache.dubbo.rpc.protocol.ProtocolFilterWrapper#export 代碼來看,buildInvokerChain會(huì)構(gòu)建provider的Filter鏈:

public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
    if (UrlUtils.isRegistry(invoker.getUrl())) {
        return protocol.export(invoker);
    }
    // invoker就是直接調(diào)用對(duì)應(yīng)方法的代碼,JavassistProxyFactory
    return protocol.export(buildInvokerChain(invoker, SERVICE_FILTER_KEY, CommonConstants.PROVIDER));
}
 

從上述代碼來看,buildInvokerChain就是構(gòu)建Filter鏈的邏輯,通過SPI方式進(jìn)行加載,F(xiàn)Ilter配置路徑為META-INF/dubbo/internal/org.apache.dubbo.rpc.Filter,配置內(nèi)容如下:

echo=org.apache.dubbo.rpc.filter.EchoFilter
generic=org.apache.dubbo.rpc.filter.GenericFilter
genericimpl=org.apache.dubbo.rpc.filter.GenericImplFilter
token=org.apache.dubbo.rpc.filter.TokenFilter
accesslog=org.apache.dubbo.rpc.filter.AccessLogFilter
activelimit=org.apache.dubbo.rpc.filter.ActiveLimitFilter
classloader=org.apache.dubbo.rpc.filter.ClassLoaderFilter
context=org.apache.dubbo.rpc.filter.ContextFilter
consumercontext=org.apache.dubbo.rpc.filter.ConsumerContextFilter
exception=org.apache.dubbo.rpc.filter.ExceptionFilter
executelimit=org.apache.dubbo.rpc.filter.ExecuteLimitFilter
deprecated=org.apache.dubbo.rpc.filter.DeprecatedFilter
compatible=org.apache.dubbo.rpc.filter.CompatibleFilter
timeout=org.apache.dubbo.rpc.filter.TimeoutFilter
 

注意,上述配置的Filter是包括Consumer和Provider的,初始化provider只會(huì)用到provider側(cè)的Filter配置,具體Filter實(shí)現(xiàn)類會(huì)通過group來區(qū)分PROVIDER或者CONSUMER,對(duì)應(yīng)的buildInvokerChain邏輯如下:

private static <T> Invoker<T> buildInvokerChain(final Invoker<T> invoker, String key, String group) {
    Invoker<T> last = invoker;
    List<Filter> filters = ExtensionLoader.getExtensionLoader(Filter.class).getActivateExtension(invoker.getUrl(), key, group);

    if (!filters.isEmpty()) {
        for (int i = filters.size() - 1; i >= 0; i--) {
            final Filter filter = filters.get(i);
            final Invoker<T> next = last;
            last = new Invoker<T>() {
                @Override
                public Result invoke(Invocation invocation) throws RpcException {
                    return filter.invoke(next, invocation);
                }
            };
        }
    }
    return last;
}
 

buildInvokerChain邏輯會(huì)按照順序進(jìn)行構(gòu)建Filter過濾鏈,由于FIlter實(shí)現(xiàn)類未設(shè)置@Activate注解的順序,因此Filter過濾鏈的前后順序就是在META-INF/dubbo/internal/org.apache.dubbo.rpc.Filter文件配置的順序,這點(diǎn)要注意。

到此,關(guān)于“Dubbo Provider Filter鏈?zhǔn)窃趺礃?gòu)建的”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí),請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站,小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI