Dubbo源码一：【Dubbo与Spring整合】

正常在项目中，我们都是在Spring环境下使用Dubbo，所以我们这里就在Spring的环境下看看Dubbo是如何运作的

入口

在源码下载下来之后，有一个dubbo-demo目录，里面有一个基于spring注解的子目录dubbo-demo-annotation, 里面有一个生产者的demo，还有一个消费者的demo
image.png
Provider下面的Application：

public class Application {public static void main(String[] args) throws Exception {AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(ProviderConfiguration.class);context.start();System.in.read();}/*** 1、EnableDubbo* 2、DubboBootstrapApplicationListener监听容器启动事件，然后调用DubboBootstrap的start方法*          1、会导出DubboService*          2、会订阅DubboService* 3、*/@Configuration@EnableDubbo(scanBasePackages = "org.apache.dubbo.demo.provider")@PropertySource("classpath:/spring/dubbo-provider.properties")static class ProviderConfiguration {@Beanpublic RegistryConfig registryConfig() {RegistryConfig registryConfig = new RegistryConfig();registryConfig.setAddress("zookeeper://127.0.0.1:2181");return registryConfig;}}
}

dubbo-provider.properties
image.png

Consumer下面的Application：

public class Application {/*** In order to make sure multicast registry works, need to specify '-Djava.net.preferIPv4Stack=true' before* launch the application*/public static void main(String[] args) {AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(ConsumerConfiguration.class);context.start();DemoService service = context.getBean("demoServiceComponent", DemoServiceComponent.class);String hello = service.sayHello("world");System.out.println("result :" + hello);}@Configuration@EnableDubbo(scanBasePackages = "org.apache.dubbo.demo.consumer.comp")@PropertySource("classpath:/spring/dubbo-consumer.properties")@ComponentScan(value = {"org.apache.dubbo.demo.consumer.comp"})static class ConsumerConfiguration {}
}

dubbo-consumer.properties
image.png

Provider#Application

@PropertySource(“classpath:/spring/dubbo-provider.properties”)

这个注解是Spring注解，负责解析配置文件，把解析到的文件放到Environment对象中。而Dubbo就是从这个对象里面拿到配置值，生成对应的对象，比如 dubbo.application.name会生成一个ApplicationConfig，比如dubbo.protocal.* 会生成一个ProtocalConfig对象

@EnableDubbo(scanBasePackages = “org.apache.dubbo.demo.provider”)

image.png

@EnableDubboConfig

完成对Dubbo配置的解析，把配置文件里面的内容解析成一个一个配置对象
image.png

import一个DubboConfigConfigurationRegistrar
  public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {/** 此方法主要作用：* 会对Properties文件进行解析，主要完成的事情是根据Properties文件的每个配置项的前缀、参数名、参数值生成对应的Bean。*  比如前缀为"dubbo.application"的配置项，会生成一个 ApplicationConfig  类型的BeanDefinition。*  比如前缀为"dubbo.protocol"的配置项，会生成一个  ProtocolConfig  类型的BeanDefinition。**  都有哪些配置类？ 具体看：*    1、DubboConfigConfiguration.Single*    2、DubboConfigConfiguration.Multiple*/AnnotationAttributes attributes = AnnotationAttributes.fromMap(importingClassMetadata.getAnnotationAttributes(EnableDubboConfig.class.getName()));boolean multiple = attributes.getBoolean("multiple");// Single Config Bindings// todo 在解析DubboConfigConfiguration.Single会注入ConfigurationBeanBindingsRegisterregisterBeans(registry, DubboConfigConfiguration.Single.class);if (multiple) { // Since 2.6.6 https://github.com/apache/dubbo/issues/3193/*** 默认情况下开启了multiple模式，multiple模式表示开启多配置模式，意思是这样的：1、如果没有开启multiple模式，那么只支持配置一个dubbo.protocol，比如：dubbo.protocol.name=dubbodubbo.protocol.port=20880dubbo.protocol.host=0.0.0.02、如果开启了multiple模式，那么可以支持多个dubbo.protocol，比如：dubbo.protocols.p1.name=dubbodubbo.protocols.p1.port=20880dubbo.protocols.p1.host=0.0.0.0dubbo.protocols.p2.name=httpdubbo.protocols.p2.port=8082dubbo.protocols.p2.host=0.0.0.0*/registerBeans(registry, DubboConfigConfiguration.Multiple.class);}// Since 2.7.6 todo 看这里registerCommonBeans(registry);}

总结一下做了几件事：

  1. 先往Spring容器注册了一个DubboConfigConfiguration.Single.class, 导致上面有注解引入了@EnableConfigurationBeanBindings

image.png
image.png

在EnableConfigurationBeanBindings上面import了ConfigurationBeanBindingsRegister, 又是相似的套路
image.png
ConfigurationBeanBindingsRegister也实现了ImportBeanDefinitionRegistrar接口，所以也会在Spring启动的时候调用到，我们能看到它做了做了几步

  1. 从EnableConfigurationBeanBindings 中获取注解的值，然后在获取value的属性值，value对应的是EnableConfigurationBeanBinding 中的值

image.png

  1. 创建一个ConfigurationBeanBindingRegistrar�类，将environment设置到里面，然后调用registerConfigurationBeanDefinitions方法

image.png
image.png
image.png
registerConfigurationBeanDefinition这里做了这样几件事：
1、从注解中获取prefix（如果里面有占位符，需要从environment中获取）、type（返回是一个class值，比如ApplicationConfig）、multiple
2、registerConfigurationBeans -> PropertySourcesUtils.getSubProperties从配置文件中取出对应的配置
3、registerConfigurationBeans -> registerConfigurationBean：将对应的Config（比如ApplicationConfig）注册到spring容器中
4、！！！registerConfigurationBindingBeanPostProcessor(registry)：注册了一个ConfigurationBeanBindingPostProcessor�, 为什么需要这个类，因为目前我们只是把配置类做成BD放到Spring容器中，但是我们并没有赋值，所以需要在这个后置处理器中给这些BD赋值

  1. 如果开启了multiple, 会往spring中注册一个DubboConfigConfiguration.Multiple.class
  2. 调用registerCommonBeans, 往Spring容器中配置很多Dubbo需要的Bean，比如ReferenceAnnotationBeanPostProcessor�（处理@dubbo_reference注解的）、DubboApplicationListenerRegistrar�（用来创建很多的Listener，在spring启动过程中，dubbo需要做的一些事）等

image.png

总结一下DubboConfigConfigurationRegistrar做的事
  1. 往Spring容器中放一个DubboConfigConfiguration.Single�类，

image.png
Single就是一个配置模版类，上面会有@EnableConfigurationBeanBindings，这个类又会注入一个类ConfigurationBeanBindingsRegister�，这个类实现了ImportBeanDefinitionRegistrar�， 会在Spring启动的时候调用到它的registerBeanDefinitions，这个方法最终完成了将Single上面这些个配置
image.png
转换成XXXConfig， 同时还注册了一个ConfigurationBeanBindingPostProcessor，完成从配置文件读取这一个个配置，并放到XXXConfig中

  1. 如果配置的multiple=true，就会多走一套multiple配置逻辑，核心逻辑和Single其实差不错
  2. registerCommonBeans：注册了很多Dubbo中用到的通用bean

�

@DubboComponentScan

image.png
�这里同样引入了一个DubboComponentScanRegistrar，也就是在spring启动的过程中会调用到它的registerBeanDefinitions方法
image.png
getPackagesToScan: 返回一个需要扫描的路径集合

image.png

registerServiceAnnotationBeanPostProcessor(packagesToScan, registry): 又往spring容器中注册了一个ServiceAnnotationBeanPostProcessor类，通过传入了刚刚获取的需要扫描的路径集合
image.png

ServiceAnnotationBeanPostProcessor

image.png
ServiceAnnotationBeanPostProcessor继承的是ServcieClassPostProcessor
image.png
image.png
这里做了几件事：

  1. 注册DubboBootstrapApplicationListener到spring容器中，这个listener负责监听ContextRefreshedEvent事件
  2. 如果packagesToScan中有占位符，替换掉，然后使用registerServiceBeans, 将@DubboServcie扫描到Spring容器中

ServiceClassPostProcessor.registerServiceBeans(packagesToScan, BeanDefinitionRegistry registry)

image.png
总结一下：

  1. 创建了一个DubboClassPathBeanDefinitionScanner专门用来扫指定路径包下面的beanDefinition的
  2. 给scanner设置了IncludeFilter，就是我只扫@DubboService、@Service这些注解的
  3. 遍历路径包，然后使用scanner.scan来看路径包下面有@DubboService、@Service的beanDefinition
  4. 将扫到的BeanDefinition，然后调用registerServiceBean 将这些spring的bean处理成Dubbo自己的bean

ServiceClassPostProcessor.registerServiceBean()

image.png

�

Consumer#Application

image.png

Consumer的大体逻辑和Provider一样，肯定也有读取配置的地方，最重要的地方就是@DubboReference是如何解析的

入口

@EnableDubboConfig -> @Import(DubboConfigConfigurationRegistrar.class) ->DubboConfigConfigurationRegistrar�.registerBeanDefinitions ->registerCommonBeans(registry);
image.png

ReferenceAnnotationBeanPostProcessor

image.png
这个类其实挺有意思的，它继承了AbstractAnnotationBeanPostProcessor，
image.png
这个AbstractAnnotationBeanPostProcessor又继承了InstantiationAwareBeanPostProcessorAdapter�，我们来看一下它的实现类有哪些？
image.png
是不是非常的熟悉，AutoWiredAnnotationBeanPostProcessor，其实@ReferencService和@AutoWired的实现原理是一样的，都是在Spring依赖注入的时候，需要做属性的注入，最终会调用到ReferenceAnnotationBeanPostProcessor.doGetInjectedBean

ReferenceAnnotationBeanPostProcessor.doGetInjectedBean

image.png
一共做了几件事：

  1. buildReferencedBeanName�

image.png
image.png
使用buildReferencedBeanName方法得到一个bean的名字，这个bean是需要引入服务的beanName，最终生成的格式为ServiceBean:org.apache.dubbo.demo.DemoService，如果说设置了group，或者version，都会拼接上去，最终生成的格式为：ServiceBean：interfaceClassName：version：group

  1. getReferenceBeanName�

image.png
image.png
getReferencBeanName得到的referenceBeanName是我引入时产生的服务名，而referencedBeanName对应的serviceBean的服务名称，从generateReferenceBeanName我们看的出来，referenceBeanName产生规则为：@Reference注解所有属性的值进行拼接，所以就是@Reference引入的接口是同一个，但注解的值不一样的话，这个名字也是不一样的。那么这个名字有什么用，他的作用是放到缓存中作为key

  1. buildReferenceBeanIfAbsent�

image.png
image.png
image.png

代码主要就是判断缓存中是否存在，如果不存在就进行创建流程，这里比较复杂，我们关系最终得到的referenceBean:
image.png

  1. isLocalServiceBean�

判断是否是本地服务

  1. registerReferenceBean�

image.png
�
�

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

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

相关文章

【PyQt】10 QLineEdit

【PyQt】10 QLineEdit

文章目录 前言一、回显模式（EchoMode）1.1 四种回显模式1.2 代码展示运行结果 二、校验器2.1 代码2.2 运行结果 三、通过掩码限制输入3.1 代码3.2 运行结果 总结 前言 1、QLineEdit 可以输入单行文字 2、回显模式 3、校验器 4、掩码输入 一、回显模式&am…
阅读更多...
k8s-资源限制与监控 15

k8s-资源限制与监控 15

资源限制 上传实验所需镜像 Kubernetes采用request和limit两种限制类型来对资源进行分配。 request(资源需求)：即运行Pod的节点必须满足运行Pod的最基本需求才能 运行Pod。 limit(资源限额)：即运行Pod期间，可能内存使用量会增加&#xff0…
阅读更多...
Jupyter Notebook如何在E盘打开

Jupyter Notebook如何在E盘打开

Jupyter Notebook如何在E盘打开 方法1：方法2： 首先打开Anaconda Powershell Prompt, 可以看到默认是C盘。 可以对应着自己的界面输入： 方法1： (base) PS C:\Users\bella> E: (base) PS E:\> jupyter notebook方法2&#x…
阅读更多...
跳表详解和实现｜深挖Redis底层数据结构

跳表详解和实现｜深挖Redis底层数据结构

文章目录 跳表前言项目代码仓库认识跳表跳表的实现思路跳表性能分析对比平衡树（avl和红黑树）和哈希表使用手册成员变量成员函数构造析构迭代器sizeclearemptyoperatorfindinserterase 跳表细节实现节点定义跳表结构定义构造、析构、拷贝构造和赋值重载si…
阅读更多...
人工智能算法：理解其工作原理及其在现实世界中的应用

人工智能算法：理解其工作原理及其在现实世界中的应用

随着科技的飞速发展，人工智能（AI）已逐渐成为我们生活中不可或缺的一部分。从智能语音助手到自动驾驶汽车，再到医疗诊断系统，人工智能算法正以前所未有的速度改变着我们的世界。本文将带您深入探讨人工智能算法的工作原…
阅读更多...
【MySQL】数据库的基础——数据库的介绍、MySQL的介绍和架构、SQL分类、MySQL的基本使用、MySQL的存储引擎

【MySQL】数据库的基础——数据库的介绍、MySQL的介绍和架构、SQL分类、MySQL的基本使用、MySQL的存储引擎

文章目录 MySQL1. 数据库的介绍1.2 主流数据库 2. MySQL的介绍2.1 MySQL架构2.2 SQL分类2.3 MySQL的基本使用2.4 MySQL存储引擎 MySQL 1. 数据库的介绍 数据库（Database，简称DB）是按照数据结构来组织、存储和管理数据的仓库。它是长期存储在计…
阅读更多...
uni-app x，一个纯原生的Android App开发工具

uni-app x，一个纯原生的Android App开发工具

uni-app x，下一代uni-app，一个神奇的产品。 用vue语法、uni的组件、api，以及uts语言，编译出了kotlin的app。不再使用js引擎和webview。纯纯的kotlin原生app。 uni-app x，让“跨平台开发性能不如原生”的这条曾广为流…
阅读更多...
LLM之LangChain（七）| 使用LangChain，LangSmith实现Prompt工程ToT

LLM之LangChain（七）| 使用LangChain，LangSmith实现Prompt工程ToT

如下图所示，LLM仍然是自治代理的backbone，可以通过给LLM增加以下模块来增强LLM功能: Prompter AgentChecker ModuleMemory moduleToT controller 当解决具体问题时，这些模块与LLM进行多轮对话。这是基于LLM的自治代理的典型情况，…
阅读更多...
Linux 命令基础

Linux 命令基础

Shell概述 Linux操作系统的Shell作为操作系统的外壳，为用户提供使用操作系统的接口。它是命令语言、命令解释程序及程序设计语言的统称。 Shell是用户和Linux内核之间的接口程序，如果把硬件想象成一个球体的中心，内核围绕在硬件的外层管理着…
阅读更多...
keil调试出现cannot evaluate新思路

keil调试出现cannot evaluate新思路

我在用最新的keil时也出现了这个问题，网上说的办法几乎没啥用，包括魔术棒的设置和将变量定义为全局变量，都没用。 这里我使用的是keil5.13，编译器是AC6.21，硬件是STM32F407VET6 可以看到，即使是定义为全局变…
阅读更多...
问题：超声波纵波斜入射时，当入射角大于第一临界角小于第二临界角时，在第二介质内只有折射横波。 #微信#经验分享#其他

问题：超声波纵波斜入射时，当入射角大于第一临界角小于第二临界角时，在第二介质内只有折射横波。 #微信#经验分享#其他

问题：超声波纵波斜入射时，当入射角大于第一临界角小于第二临界角时，在第二介质内只有折射横波。 参考答案如图所示
阅读更多...
对于模糊查询的SQL，怎么优先返回等值记录

对于模糊查询的SQL，怎么优先返回等值记录

说明：记录一次SQL改进的方法，希望能对大家有启发。 场景 前端项目有一个输入框，根据输入的银行名称，去模糊查询对应的数据库表，返回结果集，显示到下拉列表中。 因为银行名称字段包括了分行名&#xff0c…
阅读更多...
缓存穿透、缓存击穿与缓存雪崩

缓存穿透、缓存击穿与缓存雪崩

缓存穿透、缓存击穿与缓存雪崩 1.本质区别 缓存穿透指的是数据库不存在数据，导致无法缓存，每次查询都查数据库，数据库压垮 缓存击穿指的是缓存键值对key过期了，key过期期间，大量请求访问，不经过缓存&…
阅读更多...
ONLYOFFICE桌面编辑器8.0新特性：PDF表单、RTL支持、Moodle集成、本地界面主题等

ONLYOFFICE桌面编辑器8.0新特性：PDF表单、RTL支持、Moodle集成、本地界面主题等

ONLYOFFICE是由领先的IT公司—Ascensio System SIA经验丰富的IT专家开发的项目。这是一款强大的在线编辑器，能够为提供高效的文本文档、电子表格、演示文稿、表单和 PDF 编辑工具。 继 ONLYOFFICE 文档 v8.0发布后，适用于 Linux、Windows 和 macOS 的免费…
阅读更多...
C++中类的6个默认成员函数【构造函数】 【析构函数】

C++中类的6个默认成员函数【构造函数】 【析构函数】

文章目录 前言构造函数构造函数的概念构造函数的特性 析构函数 前言 在学习C我们必须要掌握的6个默认成员函数，接下来本文讲解2个默认成员函数 构造函数 如果一个类中什么成员都没有，简称为空类。 空类中真的什么都没有吗？并不是&#xff0c…
阅读更多...
电商网站基础布局——以小兔鲜为例

电商网站基础布局——以小兔鲜为例

项目准备 /* base.css */ /* 內减模式 */ * {margin: 0;padding: 0;box-sizing: border-box; }/* 设置网页统一的字体大小、行高、字体系列相关属性 */ body {font: 16px/1.5 "Helvetica Neue", Helvetica, Arial, "Microsoft Yahei","Hiragino Sans…
阅读更多...
Codeforces Round 106 D. Coloring Brackets 【区间DP + 记忆化搜索实现】

Codeforces Round 106 D. Coloring Brackets 【区间DP + 记忆化搜索实现】

D. Coloring Brackets 约定 ∣ S ∣ ≤ 700 |S| \leq 700 ∣S∣≤700 题意 给定一个正则括号序列 s s s，我们需要求出合法的染色方案数。合法的条件为： 每个符号要么不染色，要么染红色，要么染蓝色对于每对配对的括号&#xf…
阅读更多...
（十八）springboot实战——spring securtity注解方式的授权流程源码解析

（十八）springboot实战——spring securtity注解方式的授权流程源码解析

前言 在上一节内容中，我们介绍了如何在FilterSecurityInterceptor过滤器中处理用户的授权流程，并分析了其源码，spring security还提供了方法级别的授权方式，通过EnableMethodSecurity注解启用权限认证流程，只需要在方…
阅读更多...
Ivanti Pulse Connect Secure VPN SSRF(CVE-2023-46805)漏洞

Ivanti Pulse Connect Secure VPN SSRF(CVE-2023-46805)漏洞

免责声明：文章来源互联网收集整理，请勿利用文章内的相关技术从事非法测试，由于传播、利用此文所提供的信息或者工具而造成的任何直接或者间接的后果及损失，均由使用者本人负责，所产生的一切不良后果与文章作者无关。该…
阅读更多...
Failed to construct ‘RTCIceCandidate‘ sdpMid and sdpMLineIndex are both null

Failed to construct ‘RTCIceCandidate‘ sdpMid and sdpMLineIndex are both null

最近在搞webrtc，在编写函数处理远端传递来的candidate时报错了，具体信息如下。国内关于webrtc的资料很少，所以去国外社区转了一圈，回来记录一下报错的解决方案 其实这个bug也好解决，根据报错信息可以判断是RTCIceCand…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023