写点什么

Dubbo 如何支持本地调用?InJvm 方式解析,农民工看完都会了

作者:Java高工P7
  • 2021 年 11 月 09 日
  • 本文字数:1305 字

    阅读完需:约 4 分钟

}


public static InjvmProtocol getInjvmProtocol() {if (INSTANCE == null) {ExtensionLoader.getExtensionLoader(Protocol.class).g


《Android学习笔记总结+最新移动架构视频+大厂安卓面试真题+项目实战源码讲义》
浏览器打开:qq.cn.hn/FTe 免费领取
复制代码


etExtension(InjvmProtocol.NAME); // load}return INSTANCE;}


@Overridepublic <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {return new InjvmExporter<T>(invoker, invoker.getUrl().getServiceKey(), exporterMap);}


@Overridepublic <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 releasereturn true;} else if (Constants.SCOPE_REMOTE.equals(scope)) {// it's declared as remote referencereturn false;} else if (url.getParameter(Constants.GENERIC_KEY, false)) {// generic invocation is not local referencereturn false;} else if (getExporter(exporterMap, url) != null) {// by default, go through local reference if there's the service exposed locallyreturn true;} else {return false;}}

本地调用同样经过 Filter 链

与真正的本地方法调用不同的是,Dubbo 本地调用会经过 Filter 链,其中包括了 Consumer 端的 Filter 链以及 Provider 端的 Filter 链。


通过这样的机制,本地消费者和其他消费者都是统一对待,统一监控,服务统一进行治理。


如何开启本地调用

默认情况下,本地调用是自动开启的,不需要做额外的配置。只有只有当需要关闭的时候,才需要通过 scope 的配置来显式的关闭。


但是,特别需要指出的是,在下面的几种情况下,本地调用是无法使用的:


第一,泛化调用的时候无法使用本地调用。


第二,消费者明确指定 URL 发起直连调用。当然,如果消费者指定的是 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 协议的暴露,这样,即使是本地调用者,也需要从注册中心上获取服务地址列表,然后才能发起调用,


而这个时候的调用过程,与远端的服务消费者的过程是一致的。


用户头像

Java高工P7

关注

还未添加个人签名 2021.11.08 加入

还未添加个人简介

评论

发布
暂无评论
Dubbo如何支持本地调用?InJvm方式解析,农民工看完都会了