Dubbo 3.x源码(20)—Dubbo服务引用源码(3)

news2024/11/27 8:45:50

基于Dubbo 3.1，详细介绍了Dubbo服务的发布与引用的源码。

此前我们学习了调用createProxy方法，根据服务引用参数map创建服务接口代理引用对象的整体流程，我们知道会调用createInvokerForRemote方法创建远程引用Invoker，这是Dubbo 3 服务引用的核心方法，我们现在来接着学习createInvokerForRemote方法。

Dubbo 3.x服务引用源码：

  1. Dubbo 3.x源码(11)—Dubbo服务的发布与引用的入口
  2. Dubbo 3.x源码(18)—Dubbo服务引用源码(1)
  3. Dubbo 3.x源码(19)—Dubbo服务引用源码(2)
  4. Dubbo 3.x源码(20)—Dubbo服务引用源码(3)

Dubbo 3.x服务发布源码：

  1. Dubbo 3.x源码(11)—Dubbo服务的发布与引用的入口
  2. Dubbo 3.x源码(12)—Dubbo服务发布导出源码(1)
  3. Dubbo 3.x源码(13)—Dubbo服务发布导出源码(2)
  4. Dubbo 3.x源码(14)—Dubbo服务发布导出源码(3)
  5. Dubbo 3.x源码(15)—Dubbo服务发布导出源码(4)
  6. Dubbo 3.x源码(16)—Dubbo服务发布导出源码(5)
  7. Dubbo 3.x源码(17)—Dubbo服务发布导出源码(6)

文章目录

  • 1 createInvokerForRemote创建远程引用Invoker
  • 2 Protocol$Adaptive自适应Protocol
  • 3 ProtocolSerializationWrapper协议序列化包装器
  • 4 ProtocolFilterWrapper协议过滤器包装器
  • 5 ProtocolListenerWrapper协议监听器包装器
  • 6 总结

1 createInvokerForRemote创建远程引用Invoker

远程引用或者直连引用情况下，将会调用该方法，创建远程引用Invoker。该方法对于一个注册中心url和多个注册中心url的处理不一样，我们仅看一个注册中心的情况。

一个注册中心的情况下，该方法主要逻辑就是执行protocolSPI.refer方法，通过协议protocolSPI引用服务Invoker。

这里的protocolSPI是Protocol的自适应扩展实现，即Protocol$Adaptive，将会根据url的协议选择Protocol实现，然后调用Protocol#refer方法引用服务。

我们下面主要看protocolSPI#refer方法方法的相关源码，这也是Dubbo服务引入的核心流程之一。

/**
 * ReferenceConfig的方法
 * <p>
 * 创建远程引用Invoker
 */
@SuppressWarnings({"unchecked", "rawtypes"})
private void createInvokerForRemote() {
    //一个url，表示一个注册中心或者直连地址，这是大多数情况
    //url例如： registry://47.94.229.245:2181/org.apache.dubbo.registry.RegistryService?REGISTRY_CLUSTER=demo1&application=demo-consumer&dubbo=2.0.2&pid=34457&registry=zookeeper&timeout=20000&timestamp=1666854892012
    if (urls.size() == 1) {
        //获取注册中心协议url
        URL curUrl = urls.get(0);
        /*
         * 通过协议protocolSPI引用服务，该方法固定返回InjvmInvoker实例，内部没有NettyClient，因为不需要发起网络调用
         *
         * 这里的protocolSPI是Protocol的自适应扩展实现，即Protocol$Adaptive
         * 将会根据url的协议选择Protocol实现，然后调用Protocol#refer方法引用服务
         */
        invoker = protocolSPI.refer(interfaceClass, curUrl);
        // registry url, mesh-enable and unloadClusterRelated is true, not need Cluster.
        //如果是registry url（非直连地址）, 或者unloadClusterRelated为true，那么不需要Cluster，否则需要Cluster包装
        //对于远程注册中心协议来说，在protocolSPI.refer方法中就已经进行了Cluster包装，这里不再需要了
        if (!UrlUtils.isRegistry(curUrl) &&
            !curUrl.getParameter(UNLOAD_CLUSTER_RELATED, false)) {
            List<Invoker<?>> invokers = new ArrayList<>();
            invokers.add(invoker);
            invoker = Cluster.getCluster(scopeModel, Cluster.DEFAULT).join(new StaticDirectory(curUrl, invokers), true);
        }
    }
    //多个url，表示多个注册中心或者直连地址
    else {
        List<Invoker<?>> invokers = new ArrayList<>();
        URL registryUrl = null;
        for (URL url : urls) {
            // For multi-registry scenarios, it is not checked whether each referInvoker is available.
            // Because this invoker may become available later.
            invokers.add(protocolSPI.refer(interfaceClass, url));

            if (UrlUtils.isRegistry(url)) {
                // use last registry url
                registryUrl = url;
            }
        }

        if (registryUrl != null) {
            // registry url is available
            // for multi-subscription scenario, use 'zone-aware' policy by default
            String cluster = registryUrl.getParameter(CLUSTER_KEY, ZoneAwareCluster.NAME);
            // The invoker wrap sequence would be: ZoneAwareClusterInvoker(StaticDirectory) -> FailoverClusterInvoker
            // (RegistryDirectory, routing happens here) -> Invoker
            invoker = Cluster.getCluster(registryUrl.getScopeModel(), cluster, false).join(new StaticDirectory(registryUrl, invokers), false);
        } else {
            // not a registry url, must be direct invoke.
            if (CollectionUtils.isEmpty(invokers)) {
                throw new IllegalArgumentException("invokers == null");
            }
            URL curUrl = invokers.get(0).getUrl();
            String cluster = curUrl.getParameter(CLUSTER_KEY, Cluster.DEFAULT);
            invoker = Cluster.getCluster(scopeModel, cluster).join(new StaticDirectory(curUrl, invokers), true);
        }
    }
}

2 Protocol$Adaptive自适应Protocol

Protocol$Adaptive的refer方法将会根据url的协议基于Dubbo SPI机制选择Protocol实现，然后调用Protocol#refer方法引用服务，默认dubbo协议。

/**
 * Protocol$Adaptive的方法
 * 基于url协议参数的自适应引用服务
 *
 * @param arg0 服务class
 * @param arg1 远程服务的url地址
 * @return Invoker
 */
public org.apache.dubbo.rpc.Invoker refer(java.lang.Class arg0, org.apache.dubbo.common.URL arg1) throws org.apache.dubbo.rpc.RpcException {
    if (arg1 == null) throw new IllegalArgumentException("url == null");
    org.apache.dubbo.common.URL url = arg1;
    //获取url协议作为扩展名，默认dubbo
    String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());
    if (extName == null)
        throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])");
    ScopeModel scopeModel = ScopeModelUtil.getOrDefault(url.getScopeModel(), org.apache.dubbo.rpc.Protocol.class);
    //基于DUbbo SPI机制查找指定扩展名的Protocol实现类，默认DubboProtocol，这里会进行wrapper包装
    org.apache.dubbo.rpc.Protocol extension = (org.apache.dubbo.rpc.Protocol) scopeModel.getExtensionLoader(org.apache.dubbo.rpc.Protocol.class).getExtension(extName);
    //通过具体的Protocol包装实现类的refer方法实现服务的引用
    return extension.refer(arg0, arg1);
}

同服务导出时一样，获取Protocol的时候，将会经过wrapper的包装。以InjvmProtocol协议为例，可以看到经过了三层包装，调用时由外向内调用，即ProtocolSerializationWrapper -> ProtocolFilterWrapper -> ProtocolListenerWrapper -> InjvmProtocol（具体的Protocol实现）。实际上Dubbo正式采用warpper机制和装饰设计模式实现类似aop的功能。

本地引入的injvm协议对应InjvmProtocol，需要引入远程接口级注册中心的registry对应InterfaceCompatibleRegistryProtocol，需要引入远程应用级注册中心的service-discovery-registry对应RegistryProtocol。
image.png
下面我们分别讲解这些wrapper和protocol是如何进行服务引入的！

3 ProtocolSerializationWrapper协议序列化包装器

protocol的最外层wrapper，它仅会在导出服务的export方法中起作用，在引入服务的refer方法中没有其他处理。

/**
 * ProtocolSerializationWrapper的方法
 */
@Override
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
    //无特殊处理
    return protocol.refer(type, url);
}

4 ProtocolFilterWrapper协议过滤器包装器

这个包装器首先会判断如果是注册中心的协议，例如registry或者service-discovery-registry，那么直接调用下一层refer方法。

否则，获取服务url对应的Filter并且构建为一个InvokerChain对象返回，内部包含了一个下层refer方法的Invoker和一条过滤器调用链。

/**
 * ProtocolFilterWrapper的方法
 */
@Override
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
    //如果是注册中心的协议，例如registry或者service-discovery-registry，那么直接调用下一层refer方法
    if (UrlUtils.isRegistry(url)) {
        return protocol.refer(type, url);
    }
    //获取服务url对应的Filter并且构建为一个InvokerChain对象返回，内部包含了一个下层refer方法的Invoker和一条过滤器调用链。
    FilterChainBuilder builder = getFilterChainBuilder(url);
    return builder.buildInvokerChain(protocol.refer(type, url), REFERENCE_FILTER_KEY, CommonConstants.CONSUMER);
}

5 ProtocolListenerWrapper协议监听器包装器

这个包装器首先会判断如果是注册中心的协议，例如registry或者service-discovery-registry，那么直接调用下一层refer方法。

否则，调用下一层refer方法获取返回的Invoker，如果url不包含registry-cluster-type参数，将返回的Invoker包装为ListenerInvokerWrapper，内部包含了一个Invoker和一个监听器列表。

/**
 * ProtocolListenerWrapper的方法
 */
@Override
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
    //如果是注册中心的协议，例如registry或者service-discovery-registry，那么直接调用下一层refer方法
    if (UrlUtils.isRegistry(url)) {
        return protocol.refer(type, url);
    }
    //调用下一层refer方法获取返回的Invoker
    Invoker<T> invoker = protocol.refer(type, url);
    //如果url不包含registry-cluster-type参数
    if (StringUtils.isEmpty(url.getParameter(REGISTRY_CLUSTER_TYPE_KEY))) {
        //将返回的Invoker包装为ListenerInvokerWrapper，内部包含了一个Invoker和一个监听器列表
        invoker = new ListenerInvokerWrapper<>(invoker,
                Collections.unmodifiableList(
                    ScopeModelUtil.getExtensionLoader(InvokerListener.class, invoker.getUrl().getScopeModel())
                                .getActivateExtension(url, INVOKER_LISTENER_KEY)));
    }
    return invoker;
}

6 总结

本次我们学习了createInvokerForRemote方法中的Wrapper有哪些以及作用，接下来我们将会的学习真正的本地、应用级别、接口级别的Protocol的引入逻辑。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1805271.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

开启数字化校园解决方案，实现教育智能化

开启数字化校园解决方案，实现教育智能化

现代社会的教育面临诸多挑战&#xff0c;如何提高教育质量&#xff0c;实现教育智能化成为了当务之急。数字化校园解决方案应运而生&#xff0c;为学校提供了全新的教学模式和管理方式。本文将介绍数字化校园解决方案的重要性&#xff0c;以及如何开启数字化校园&#xff0c;实…
阅读更多...
客户案例｜Zilliz Cloud 助力点石科技转型 AI 智能服务商

客户案例｜Zilliz Cloud 助力点石科技转型 AI 智能服务商

福建点石科技网络科技有限公司成立于2010年&#xff0c;是国家高新技术企业&#xff0c;阿里云、蚂蚁金服等大厂海内外生态合作伙伴ISV。在餐饮、零售、酒店、旅游、商圈的行业定制化服务化上有深厚积累&#xff0c;在境内外做了大量标杆性软件项目&#xff0c;如东南亚RWS圣淘…
阅读更多...
《python程序语言设计》2018版第5章第46题均值和标准方差-上部（我又一次被作者的出题击倒）

《python程序语言设计》2018版第5章第46题均值和标准方差-上部（我又一次被作者的出题击倒）

第N次被作者打倒了&#xff0c;第5章46题解题上集的记录 计算均值的代码段 step_num 0num_c 0 pow_c 0 while step_num < 10:a eval(input("Enter number is: "))num_c apow_c pow(a, 2)step_num 1 t2 num_c / 10这个结果和书里的答案差一点。书里写的是…
阅读更多...
容器中运行ping提示bash: ping: command not found【笔记】

容器中运行ping提示bash: ping: command not found【笔记】

容器中运行ping提示bash: ping: command not found 原因是容器中没有安装ping命令 在容器中安装ping命令&#xff0c;可以使用以下命令&#xff1a; 对于基于Debian/Ubuntu的容器&#xff0c;使用以下命令&#xff1a; apt-get update apt-get install -y iputils-ping对于基…
阅读更多...
Docker run 命令常用参数详解

Docker run 命令常用参数详解

Docker run 命令提供了丰富的参数选项&#xff0c;用于配置容器的各种设置。以下是docker run命令的主要参数详解&#xff0c; 主要参数详解 后台运行与前台交互 -d, --detach: 在后台运行容器&#xff0c;并返回容器ID。-it: 分配一个伪终端&#xff08;pseudo-TTY&#xff0…
阅读更多...
如何做好电子内窥镜的网络安全管理？

如何做好电子内窥镜的网络安全管理？

电子内窥镜作为一种常用的医疗器械&#xff0c;其网络安全管理对于保护患者隐私和医疗数据的安全至关重要。以下是一些基本原则和步骤&#xff0c;用于确保电子内窥镜的网络安全&#xff1a; 1. 数据加密 为了防止数据泄露&#xff0c;电子内窥镜在传输患者图像数据时应采取有…
阅读更多...
解决！word转pdf时，怎样保持图片不失真

解决！word转pdf时，怎样保持图片不失真

#今天用word写了期末设计报告&#xff0c;里面有很多过程的截图&#xff0c;要打印出来&#xff0c;想到pdf图片不会错位&#xff0c;就转成了pdf&#xff0c;发现图片都成高糊了&#xff0c;找了好多方法&#xff0c;再不下载其他软件和插件的情况下&#xff0c;导出拥有清晰的…
阅读更多...
cf 欧几里得距离

cf 欧几里得距离

说明&#xff1a;欧几里得距离本质就是两点间距离 distancesqrt( sum(ai-bi)2 ) Problem - F - Codeforces 代码
阅读更多...
下载安装Thonny并烧录MicroPython固件至ESP32

下载安装Thonny并烧录MicroPython固件至ESP32

Thonny介绍 一、Thonny的基本特点 面向初学者&#xff1a;Thonny的设计初衷是为了帮助Python初学者更轻松、更快速地入门编程。它提供了直观易懂的用户界面和丰富的功能&#xff0c;降低了编程的门槛。轻量级&#xff1a;作为一款轻量级的IDE&#xff0c;Thonny不会占用过多的…
阅读更多...
Zookeeper高频面试题整理（入门到精通）

Zookeeper高频面试题整理（入门到精通）

文章目录 1、什么是Zookeeper&#xff1f;2、ZooKeeper的基本数据结构是什么&#xff1f;3、Zookeeper的节点类型有哪些&#xff1f;4、Zookeeper的特点5、ZooKeeper如何保证数据一致性&#xff1f;6、什么是ZAB协议&#xff1f;7、Zookeeper的ACL机制是什么&#xff1f;8、Zoo…
阅读更多...
读书笔记：左耳听风

读书笔记：左耳听风

程序员如何用技术变现 我完全没有必要通过打工听人安排而活着&#xff0c;而是反过来通过在公司工作提高自己的技能&#xff0c;让自己可以更为独立和自由地生活。 因而&#xff0c;在工作当中&#xff0c;对于那些没什么技术含量的工作&#xff0c;我基本上就像是在学生时代那…
阅读更多...
github异常问题总结

github异常问题总结

问题1&#xff1a; gitgitlab.gz.cvte.cn: Permission denied (publickey). fatal: Could not read from remote repository.Please make sure you have the correct access rights and the repository exists.解决方法&#xff1a; 这个错误表示 GitLab 服务器拒绝了你的 SSH…
阅读更多...
数据结构严蔚敏版精简版-栈和队列以及c语言代码实现

数据结构严蔚敏版精简版-栈和队列以及c语言代码实现

1栈的定义和特权 栈(stack)是限定仅在表尾进行插入或删除操作的线性表。 注&#xff1a;虽然说栈的实现就是一端插入和删除&#xff0c;但不一定是在“表尾”&#xff0c;这个“表尾”是广义的。 头插法实现链栈 尾插法实现链栈 因此&#xff0c;对栈来说&#xff0c;表尾…
阅读更多...
理解数仓建模

理解数仓建模

​​​在数仓建设的过程中&#xff0c;由于未能完全按照规范操作&#xff0c; 从而导致数据仓库建设比较混乱&#xff0c;常见有以下问题&#xff1a; 数仓常见问题 ● 数仓分层不清晰&#xff1a;数仓的分层没有明确的逻辑&#xff0c;难以管理和维护。 ● 数据域划分不明确…
阅读更多...
刷代码随想录有感（97）：动态规划——斐波那契数列

刷代码随想录有感（97）：动态规划——斐波那契数列

题干&#xff1a; 代码&#xff1a; class Solution { public:int fib(int n) {if(n < 1)return n;vector<int> dp(n 1);dp[0] 0;dp[1] 1;for(int i 2; i < n; i){dp[i] dp[i - 1] dp[i - 2];}return dp[n];} }; 动态规划五部曲&#xff1a; 1.dp数组的定…
阅读更多...
静态IP代理服务对比：哪些提供商值得信赖？静态ip代理哪家好用？

静态IP代理服务对比：哪些提供商值得信赖？静态ip代理哪家好用？

当涉及选择静态IP代理时&#xff0c;许多人可能会感到困惑&#xff0c;因为市场上存在着各种各样的选项。本文旨在为您提供一些关键指导&#xff0c;帮助您确定哪种静态IP代理是最适合您需求的。在这个过程中&#xff0c;我们将介绍一个备受推崇的解决方案——太阳HTTP。 1.高速…
阅读更多...
8. 正则表达式

8. 正则表达式

正则表达式 在处理字符串时&#xff0c;需要查找符合某些复杂规则的字符串&#xff0c;正则表达式就是用于描述这些规则的工具 一、正则表达式语法 行定位符&#xff1a;用来描述字符串的边界 -->用来匹配一整行 符号匹配位置^行的开始$行的结尾 ^tm : 可以匹配行 tm equa…
阅读更多...
Recognize Anything: A Strong Image Tagging Model（RAM模型使用方法）

Recognize Anything: A Strong Image Tagging Model（RAM模型使用方法）

一、RAM模型介绍 这篇论文介绍了一个名为“Recognize Anything Model”&#xff08;RAM&#xff09;的新型基础模型&#xff0c;专用于图像标签识别&#xff08;图像分类&#xff09;。这一模型采用大规模图像-文本配对数据进行训练&#xff0c;无需手动注释&#xff0c;能够在…
阅读更多...
Java--可变参数

Java--可变参数

1.JDK1.5开始&#xff0c;Java支持同类型的可变参数给一个方法 2.在方法声明之前&#xff0c;在指定参数类型后加一个省略号&#xff08;...&#xff09; 3.一个方法只能指定一个可变参数&#xff0c;它必须是方法的最后一个参数&#xff0c;任何普通的参数必须在它之前声明 …
阅读更多...
国产操作系统上给virtualbox中win7虚拟机安装增强工具 _ 统信 _ 麒麟 _ 中科方德

国产操作系统上给virtualbox中win7虚拟机安装增强工具 _ 统信 _ 麒麟 _ 中科方德

原文链接&#xff1a;国产操作系统上给virtualbox中win7虚拟机安装增强工具 | 统信 | 麒麟 | 中科方德 Hello&#xff0c;大家好啊&#xff01;今天给大家带来一篇在国产操作系统上给win7虚拟机安装virtualbox增强工具的文章。VirtualBox增强工具&#xff08;Guest Additions&a…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023