Dubbo 如何支持本地调用?InJvm 方式解析,阿里官方推荐
发布于: 58 分钟前
}
@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 链。
通过这样的机制,本地消费者和其他消费者都是统一对待,统一监控,服务统一进行治理。
![](https://static001.geekbang.org/infoq/95/957cda08792312978999d908a7822e9f.png)
### 如何开启本地调用
默认情况下,本地调用是自动开启的,不需要做额外的配置。只有只有当需要关闭的时候,才需要通过 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 协议的暴露,这样,即使是本地调用者,也需要从注册中心上获取服务地址列表,然后才能发起调用,
# 总结
无论是哪家公司,都很重视高并发高可用的技术,重视基础,重视JVM。面试是一个双向选择的过程,不要抱着畏惧的心态去面试,不利于自己的发挥。同时看中的应该不止薪资,还要看你是不是真的喜欢这家公司,是不是能真的得到锻炼。其实我写了这么多,只是我自己的总结,并不一定适用于所有人,相信经过一些面试,大家都会有这些感触。
最后,如果有想要我整理的面试资料的,可以**[戳这里免费领取](https://gitee.com/vip204888/java-p7)**,我整理了一些面试真题资料,技术知识点剖析教程,还有和广大同仁一起交流学习共同进步,还有一些职业经验的分享。
![面试了阿里,滴滴,网易,蚂蚁,最终有幸去了网易【面试题分享】](https://static001.geekbang.org/infoq/04/04f3cdf4e6b418404f3a7671674112a0.jpeg)
复制代码
划线
评论
复制
发布于: 58 分钟前阅读数: 3
Geek_f90455
关注
还未添加个人签名 2021.07.06 加入
还未添加个人简介
评论