Dubbo是一個遠程調用的框架重付,對于一個服務提供者,暴露了一個接口供外部消費者調用凫乖,那么對于提供者自己是否可以調用這個接口确垫,需要什么特殊處理嗎愕把?
這篇文章就分享下Dubbo關于本地調用的實現(xiàn)機制,以及如何開啟和關閉本地調用森爽。
injvm支持本地調用
使用 Dubbo 本地調用不需做特殊配置恨豁,按正常 Dubbo 服務暴露服務即可。
任一服務在暴露遠程服務的同時爬迟,也會同時以 injvm 的協(xié)議暴露本地服務橘蜜。injvm 是一個偽協(xié)議,不會像其他協(xié)議那樣對外開啟端口付呕,只用于本地調用的目的计福。
InjvmProtocol源碼學習
injvm相關的代碼實現(xiàn)在Dubbo-rpc-injvm模塊中,主要是InjvmExporter徽职、InjvmInvoker和InjvmProtocol象颖。
InjvmProtocol 繼承 AbstractProtocol,
public class InjvmProtocol extends AbstractProtocol implements Protocol {
public static final String NAME = Constants.LOCAL_PROTOCOL;
public static final int DEFAULT_PORT = 0;
private static InjvmProtocol INSTANCE;
public InjvmProtocol() {
INSTANCE = this;
}
public static InjvmProtocol getInjvmProtocol() {
if (INSTANCE == null) {
ExtensionLoader.getExtensionLoader(Protocol.class).getExtension(InjvmProtocol.NAME); // load
}
return INSTANCE;
}
@Override
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
return new InjvmExporter<T>(invoker, invoker.getUrl().getServiceKey(), exporterMap);
}
@Override
public <T> Invoker<T> refer(Class<T> serviceType, URL url) throws RpcException {
return new InjvmInvoker<T>(serviceType, url, url.getServiceKey(), exporterMap);
}
}
除了export和refer方法姆钉,InjvmProtocol提供了isInjvmRefer()方法说订,
isInjvmRefer會讀取配置文件,判斷是否開啟本地調用潮瓶。
public boolean isInjvmRefer(URL url) {
String scope = url.getParameter(Constants.SCOPE_KEY);
// Since injvm protocol is configured explicitly, we don't need to set any extra flag, use normal refer process.
if (Constants.SCOPE_LOCAL.equals(scope) || (url.getParameter(Constants.LOCAL_PROTOCOL, false))) {
// if it's declared as local reference
// 'scope=local' is equivalent to 'injvm=true', injvm will be deprecated in the future release
return true;
} else if (Constants.SCOPE_REMOTE.equals(scope)) {
// it's declared as remote reference
return false;
} else if (url.getParameter(Constants.GENERIC_KEY, false)) {
// generic invocation is not local reference
return false;
} else if (getExporter(exporterMap, url) != null) {
// by default, go through local reference if there's the service exposed locally
return true;
} else {
return false;
}
}
本地調用同樣經過Filter鏈
與真正的本地方法調用不同的是陶冷,Dubbo 本地調用會經過 Filter 鏈,其中包括了 Consumer 端的 Filter 鏈以及 Provider 端的 Filter 鏈毯辅。通過這樣的機制埂伦,本地消費者和其他消費者都是統(tǒng)一對待,統(tǒng)一監(jiān)控思恐,服務統(tǒng)一進行治理沾谜。
如何開啟本地調用
默認情況下,本地調用是自動開啟的胀莹,不需要做額外的配置基跑。只有只有當需要關閉的時候,才需要通過 scope 的配置來顯式的關閉嗜逻。
但是涩僻,特別需要指出的是缭召,在下面的幾種情況下栈顷,本地調用是無法使用的:
第一,泛化調用的時候無法使用本地調用嵌巷。
第二萄凤,消費者明確指定 URL 發(fā)起直連調用。當然搪哪,如果消費者指定的是 injvm 的 URL靡努,最終的調用也是走本地調用的,比如:
<Dubbo:reference id="demoService" interface="org.apache.Dubbo.samples.local.api.DemoService" url="injvm://127.0.0.1/org.apache.Dubbo.samples.local.api.DemoService"/>
如何關閉本地調用
本地調用是可以顯示關閉的,通過這種方式惑朦,服務提供者可以做到對遠端服務消費者和本地消費者一視同仁兽泄。具體做法是通過 scope="remote" 來關閉 injvm 協(xié)議的暴露,這樣漾月,即使是本地調用者病梢,也需要從注冊中心上獲取服務地址列表,然后才能發(fā)起調用梁肿,而這個時候的調用過程蜓陌,與遠端的服務消費者的過程是一致的。
<bean id="target" class="org.apache.Dubbo.samples.local.impl.DemoServiceImpl"/>
<!-- 服務提供者指定 scope="remote" -->
<Dubbo:service interface="org.apache.Dubbo.samples.local.api.DemoService" ref="target" scope="remote"/>
<Dubbo:reference id="demoService" interface="org.apache.Dubbo.samples.local.api.DemoService"/>