网站建设资讯

NEWS

网站建设资讯

injvm如何实现本地调用Dubbo框架-创新互联

injvm支持本地调用

使用 Dubbo 本地调用不需做特殊配置,按正常 Dubbo 服务暴露服务即可。
任一服务在暴露远程服务的同时,也会同时以 injvm 的协议暴露本地服务。
injvm 是一个伪协议,不会像其他协议那样对外开启端口,只用于本地调用的目的。

成都创新互联公司是一家专业的成都网站建设公司,我们专注成都网站建设、网站建设、网络营销、企业网站建设,外链广告投放为企业客户提供一站式建站解决方案,能带给客户新的互联网理念。从网站结构的规划UI设计到用户体验提高,创新互联力求做到尽善尽美。

InjvmProtocol源码学习

injvm相关的代码实现在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  Exporter export(Invoker invoker) throws RpcException {
     return new InjvmExporter(invoker, invoker.getUrl().getServiceKey(), exporterMap);
   }

   @Override
   public  Invoker refer(Class serviceType, URL url) throws RpcException {
     return new InjvmInvoker(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 链。

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

injvm如何实现本地调用Dubbo框架

如何开启本地调用

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

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

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

第二,消费者明确指定 URL 发起直连调用。当然,如果消费者指定的是 injvm 的 URL,最终的调用也是走本地调用的,比如:

如何关闭本地调用

本地调用是可以显示关闭的,通过这种方式,服务提供者可以做到对远端服务消费者和本地消费者一视同仁。

具体做法是通过 scope="remote" 来关闭 injvm 协议的暴露,这样,即使是本地调用者,也需要从注册中心上获取服务地址列表,然后才能发起调用,

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




另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


文章名称:injvm如何实现本地调用Dubbo框架-创新互联
地址分享:http://cdweb.net/article/iohip.html