Dubbo如何支持本地調用粹懒?injvm方式解析

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

?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末吩蔑,一起剝皮案震驚了整個濱河市钮热,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌烛芬,老刑警劉巖隧期,帶你破解...
    沈念sama閱讀 206,214評論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異赘娄,居然都是意外死亡厌秒,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,307評論 2 382
  • 文/潘曉璐 我一進店門擅憔,熙熙樓的掌柜王于貴愁眉苦臉地迎上來鸵闪,“玉大人,你說我怎么就攤上這事暑诸“鏊希” “怎么了?”我有些...
    開封第一講書人閱讀 152,543評論 0 341
  • 文/不壞的土叔 我叫張陵个榕,是天一觀的道長篡石。 經常有香客問我,道長西采,這世上最難降的妖魔是什么凰萨? 我笑而不...
    開封第一講書人閱讀 55,221評論 1 279
  • 正文 為了忘掉前任,我火速辦了婚禮械馆,結果婚禮上胖眷,老公的妹妹穿的比我還像新娘。我一直安慰自己霹崎,他們只是感情好珊搀,可當我...
    茶點故事閱讀 64,224評論 5 371
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著尾菇,像睡著了一般境析。 火紅的嫁衣襯著肌膚如雪囚枪。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,007評論 1 284
  • 那天劳淆,我揣著相機與錄音链沼,去河邊找鬼。 笑死沛鸵,一個胖子當著我的面吹牛忆植,可吹牛的內容都是我干的。 我是一名探鬼主播谒臼,決...
    沈念sama閱讀 38,313評論 3 399
  • 文/蒼蘭香墨 我猛地睜開眼朝刊,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了蜈缤?” 一聲冷哼從身側響起拾氓,我...
    開封第一講書人閱讀 36,956評論 0 259
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎底哥,沒想到半個月后咙鞍,有當地人在樹林里發(fā)現(xiàn)了一具尸體,經...
    沈念sama閱讀 43,441評論 1 300
  • 正文 獨居荒郊野嶺守林人離奇死亡趾徽,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 35,925評論 2 323
  • 正文 我和宋清朗相戀三年续滋,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片孵奶。...
    茶點故事閱讀 38,018評論 1 333
  • 序言:一個原本活蹦亂跳的男人離奇死亡疲酌,死狀恐怖,靈堂內的尸體忽然破棺而出了袁,到底是詐尸還是另有隱情朗恳,我是刑警寧澤,帶...
    沈念sama閱讀 33,685評論 4 322
  • 正文 年R本政府宣布载绿,位于F島的核電站粥诫,受9級特大地震影響,放射性物質發(fā)生泄漏崭庸。R本人自食惡果不足惜怀浆,卻給世界環(huán)境...
    茶點故事閱讀 39,234評論 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望怕享。 院中可真熱鬧执赡,春花似錦、人聲如沸熬粗。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,240評論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽驻呐。三九已至灌诅,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間含末,已是汗流浹背猜拾。 一陣腳步聲響...
    開封第一講書人閱讀 31,464評論 1 261
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留佣盒,地道東北人挎袜。 一個月前我還...
    沈念sama閱讀 45,467評論 2 352
  • 正文 我出身青樓,卻偏偏與公主長得像肥惭,于是被迫代替她去往敵國和親盯仪。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 42,762評論 2 345

推薦閱讀更多精彩內容