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.hqwc.cn/news/464177.html

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

相关文章

【leetcode热题100】子集 II

给你一个整数数组 nums ,其中可能包含重复元素,请你返回该数组所有可能的子集(幂集)。 解集 不能 包含重复的子集。返回的解集中,子集可以按 任意顺序 排列。 示例 1: 输入:nums [1,2,2] 输出…

最高的牛(C++)

有 N头牛站成一行,被编队为 1、2、3…N每头牛的身高都为整数。 当且仅当两头牛中间的牛身高都比它们矮时,两头牛方可看到对方。 现在,我们只知道其中最高的牛是第 P 头,它的身高是 H ,剩余牛的身高未知。 但是&#xf…

git安装配置

1、下载安装 下载地址 2、配置git用户 git config --global user.name "yw" git config --global user.email "88888qq.com" 3、git init 初始化 4、生成ssh密钥 mkdir .ssh //创建文件夹cd .ssh //进入新建文件夹 ssh-keygen -t rsa // 输入密钥文…

Godot 游戏引擎个人评价和2024年规划(无代码)

文章目录 前言Godot C# .net core 开发简单评价Godot相关网址可行性 Godot(GDScirpt) Vs CocosGodot VS UnityUnity 的裁员Unity的股票Unity的历史遗留问题:Mono和.net core.net core的开发者,微软 个人的独立游戏Steam平台分成说明独立游戏的选题美术风…

【C++第二阶段】赋值运算符重载

你好你好&#xff01; 以下内容仅为当前认识&#xff0c;可能有不足之处&#xff0c;欢迎讨论&#xff01; 文章目录 赋值运算符重载 赋值运算符重载 实验①&#xff0c;还没有对析构运算符重载时 #include<iostream> #include<string> using namespace std;clas…

VR和AR傻傻分不清,一句话给你讲明白。

不说废话&#xff0c;直接说结论&#xff0c;虚拟现实&#xff08;Virtual Reality&#xff0c;VR&#xff09;和增强现实&#xff08;Augmented Reality&#xff0c;AR&#xff09;。如果现实是A&#xff0c;虚拟是B&#xff0c;那么VRB&#xff0c;ARAB&#xff0c;就这简单&…

算法学习——LeetCode力扣二叉树篇2

算法学习——LeetCode力扣二叉树篇2 107. 二叉树的层序遍历 II 107. 二叉树的层序遍历 II - 力扣&#xff08;LeetCode&#xff09; 描述 给你二叉树的根节点 root &#xff0c;返回其节点值 自底向上的层序遍历 。 &#xff08;即按从叶子节点所在层到根节点所在的层&#…

在Ubuntu22.04上部署ComfyUI

ComfyUI 是 一个基于节点流程的 Stable Diffusion 操作界面&#xff0c;可以通过流程&#xff0c;实现了更加精准的工作流定制和完善的可复现性。每一个模块都有特定的的功能&#xff0c;我们可以通过调整模块连接达到不同的出图效果&#xff0c;特点如下&#xff1a; 1.对显存…

C++笔记之regex(正则表达式)

C++笔记之regex(正则表达式) ——2024-02-10 ——《C++标准库》(第2版,侯捷译) Page 717 code review! 文章目录 C++笔记之regex(正则表达式)例1:使用正则表达式进行搜索(`std::regex_search`)例2:使用正则表达式进行全文匹配(`std::regex_match`)例3:使用正则表达式…

神经网络 | CNN 与 RNN——深度学习主力军

Hi&#xff0c;大家好&#xff0c;我是半亩花海。本文主要将卷积神经网络&#xff08;CNN&#xff09;和循环神经网络&#xff08;RNN&#xff09;这两个深度学习主力军进行对比。我们知道&#xff0c;从应用方面上来看&#xff0c;CNN 用于图像识别较多&#xff0c;而 RNN 用于…

金融信贷风控系统设计

前言 近一年多以来在金融行业负责风控系统&#xff0c;根据自己工作中的经验&#xff0c;写下这篇文章。既是对自己在风控领域工作的总结&#xff0c;也是给刚入行和准备入行的朋友打个样&#xff0c;希望能有所帮助。 为什么要有风控系统 记得 2016 年信贷行业的发展形势还…

一周学会Django5 Python Web开发-Django5创建项目(用PyCharm工具)

锋哥原创的Python Web开发 Django5视频教程&#xff1a; 2024版 Django5 Python web开发 视频教程(无废话版) 玩命更新中~_哔哩哔哩_bilibili2024版 Django5 Python web开发 视频教程(无废话版) 玩命更新中~共计11条视频&#xff0c;包括&#xff1a;2024版 Django5 Python we…