您好,登錄后才能下訂單哦!
這篇文章主要介紹“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)用棧信息如下:
從調(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í)用的文章!
免責(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)容。