injvm如何實現(xiàn)本地調(diào)用Dubbo框架-創(chuàng)新互聯(lián)

injvm支持本地調(diào)用

使用 Dubbo 本地調(diào)用不需做特殊配置，按正常 Dubbo 服務(wù)暴露服務(wù)即可。
任一服務(wù)在暴露遠(yuǎn)程服務(wù)的同時，也會同時以 injvm 的協(xié)議暴露本地服務(wù)。
injvm 是一個偽協(xié)議，不會像其他協(xié)議那樣對外開啟端口，只用于本地調(diào)用的目的。

成都創(chuàng)新互聯(lián)公司是一家專業(yè)的成都網(wǎng)站建設(shè)公司，我們專注成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)、網(wǎng)絡(luò)營銷、企業(yè)網(wǎng)站建設(shè)，外鏈，廣告投放為企業(yè)客戶提供一站式建站解決方案，能帶給客戶新的互聯(lián)網(wǎng)理念。從網(wǎng)站結(jié)構(gòu)的規(guī)劃UI設(shè)計到用戶體驗提高，創(chuàng)新互聯(lián)力求做到盡善盡美。

InjvmProtocol源碼學(xué)習(xí)

injvm相關(guān)的代碼實現(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會讀取配置文件，判斷是否開啟本地調(diào)用。

   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;
     }
   }

本地調(diào)用同樣經(jīng)過Filter鏈

與真正的本地方法調(diào)用不同的是，Dubbo 本地調(diào)用會經(jīng)過 Filter 鏈，其中包括了 Consumer 端的 Filter 鏈以及 Provider 端的 Filter 鏈。

通過這樣的機(jī)制，本地消費者和其他消費者都是統(tǒng)一對待，統(tǒng)一監(jiān)控，服務(wù)統(tǒng)一進(jìn)行治理。

如何開啟本地調(diào)用

默認(rèn)情況下，本地調(diào)用是自動開啟的，不需要做額外的配置。只有只有當(dāng)需要關(guān)閉的時候，才需要通過 scope 的配置來顯式的關(guān)閉。

但是，特別需要指出的是，在下面的幾種情況下，本地調(diào)用是無法使用的：

第一，泛化調(diào)用的時候無法使用本地調(diào)用。

第二，消費者明確指定 URL 發(fā)起直連調(diào)用。當(dāng)然，如果消費者指定的是 injvm 的 URL，最終的調(diào)用也是走本地調(diào)用的，比如：

<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"/>

如何關(guān)閉本地調(diào)用

本地調(diào)用是可以顯示關(guān)閉的，通過這種方式，服務(wù)提供者可以做到對遠(yuǎn)端服務(wù)消費者和本地消費者一視同仁。

具體做法是通過 scope="remote" 來關(guān)閉 injvm 協(xié)議的暴露，這樣，即使是本地調(diào)用者，也需要從注冊中心上獲取服務(wù)地址列表，然后才能發(fā)起調(diào)用，

而這個時候的調(diào)用過程，與遠(yuǎn)端的服務(wù)消費者的過程是一致的。

<bean id="target" class="org.apache.Dubbo.samples.local.impl.DemoServiceImpl"/>
<!-- 服務(wù)提供者指定 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"/>

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

網(wǎng)站標(biāo)題：injvm如何實現(xiàn)本地調(diào)用Dubbo框架-創(chuàng)新互聯(lián)
URL分享：http://muchs.cn/article8/iohip.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供關(guān)鍵詞優(yōu)化、小程序開發(fā)、網(wǎng)站設(shè)計、品牌網(wǎng)站建設(shè)、網(wǎng)站維護(hù)、手機(jī)網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)