深入理解Dubbo-3.高级功能剖析和原理解析

👏作者简介：大家好，我是爱吃芝士的土豆倪，24届校招生Java选手，很高兴认识大家
📕系列专栏：Spring源码、JUC源码、Kafka原理、分布式技术原理
🔥如果感觉博主的文章还不错的话，请👍三连支持👍一下博主哦
🍂博主正在努力完成2023计划中：源码溯源，一探究竟
📝联系方式：nhs19990716，加我进群，大家一起学习，一起进步，一起对抗互联网寒冬👀

文章目录

Dubbo进阶
- 多序列化支持
- 性能优化参数
- Dubbo缓存文件
- Dubbo是如何实现的
- Dubbo模块说明
- Dubbo 流程分析及扩展

Dubbo进阶

对于我们使用这个框架来说，如果会用了以后，更多的可能是需要关心一下为什么要使用这个功能？

它是怎么实现服务的注册，怎么实现服务的发现，以及怎么去动态的更新服务、怎么去负载均衡。

对于一个技术的使用来说，我们可以不去了解这个技术本身原理性的东西就可以去使用了，对于实际的应用开发来说，可能只有项目开始的时候才会去搭建这些技术的整合，配置这些组件和各种工具类等等。搭建好之后，后面大部分的开发都是 ctrl cv的动作，在框架整合来说都是可以复制粘贴的，但是对于业务来说Controller、Service本质上没什么变化。

多序列化支持

Dubbo支持多种序列化方式，包括Hessian、Java原生序列化、JSON、FastJSON、Kryo等。用户可以根据自己的需求选择合适的序列化方式来进行数据交换。这样可以提高系统的灵活性和性能，使得Dubbo可以适应不同的应用场景。

添加jar包支持

<dependency>
	<groupId>com.esotericsoftware</groupId>
	<artifactId>kryo</artifactId>
	<version>4.0.2</version>
</dependency>
<dependency>
	<groupId>de.javakaffee</groupId>
	<artifactId>kryo-serializers</artifactId>
	<version>0.45</version>
</dependency>

添加序列化支持

dubbo.protocol.serialization=kryo

客户端在调用的时候也需要加入以上操作。

多序列化的支持意味着Dubbo可以根据不同的应用场景和需求选择合适的序列化方式，从而提高系统的灵活性和性能。不同的序列化方式有不同的特点，比如Hessian序列化速度快，但占用内存较多；而JSON序列化则占用内存较少，但速度可能稍慢。因此，通过支持多序列化方式，Dubbo可以根据具体情况选择最合适的序列化方式，从而提高系统的性能和效率。另外，支持自定义序列化方式也意味着用户可以根据自己的需求实现自己的序列化方式，从而更好地满足特定的业务需求。因此，多序列化的支持可以使Dubbo更加灵活、高效地应对不同的应用场景和需求。

性能优化参数

dubbo服务里有很多性能优化的参数，这些参数无非就是线程、连接（客户端和服务端建立的连接是长连接还是短连接，是共享连接还是非共享连接）因为这些比较基础的点可能会影响整体的性能。

在这里插入图片描述

对应参数在实际链路中起作用的环节

在这里插入图片描述

首先当客户端发起一个请求的时候，针对每个服务消费者每服务每方法最大并发调用数进行了设置，当超过最大并发数的时候会被拒绝掉，这里是采用一个原子计数器去实现的。

紧接着会对连接数量做限制，这个对于很多的池化的技术组件，比如数据库连接池等都会这样做限制，这个限制本质上就是控制资源的使用。Dubbo协议是长连接协议，当客户端和服务端建立这个连接之后，这个连接不会关，一直会处于一个打开状态，后续的请求如果发现Dubbo里已经有打开的连接，那就用这个连接的通道去进行数据传输。

经过请求之后到了服务端，判断总的连接数是否超过限制。

接着到了线程层面，消耗的是cpu资源，而连接层面消耗的是内存和网络通信延迟。其实际的调优就像普遍的线程池调优一样，最后还有executes 对服务提供者每服务每方法最大可并行执行请求数进行限制。

Dubbo缓存文件

配置服务地址的缓存，避免注册中心挂了之后对于服务通信的影响

dubbo.registries.shanghai.zone=shanghai
dubbo.registries.shanghai.weight=100
dubbo.registries.shanghai.file=${user.home}/dubbo_shanghai.cache


dubbo.registries.hunan.address=nacos://192.168.216.128:8848
dubbo.registries.hunan.weight=10
dubbo.registries.hunan.preferred=true
dubbo.registries.hunan.file=${user.home}/dubbo_hunan.cache

Dubbo是如何实现的

对于一个技术的使用来说，使用的多了以后会更加的熟练，但是使用的过程中如果出现了问题，能不能快速的定位到问题，其次就是在用这个技术的时候，能不能去了解其底层是怎么实现的。

在这里插入图片描述

图中左侧蓝色区域表示服务消费者，右侧表示服务提供者，它们都是基于Interface。

消费服务的时候会经过这几个层，首先经过服务层 Service，然后到了配置层Config，该层主要是为了加载Dubbo配置的属性文件。

紧接着到了代理层，其中代理类对进行远程调用，所以代理类要去 Registry 注册层去得到具体要调用哪个服务。

而 Registry 注册层中 RegistryProtocol 基于注册中心的协议，因为 Registry 层中有不同的注册中心，该层通过 RegistryFactory 去获得注册中心的地址，然后通过 NotifyListener去动态的监听具体要调用哪个服务的地址变化，该地址以目录的方式存储在 RegistryDirectory中，里面存储了多个地址。

然后到了 Cluster 集群层，集群容错是在这里面做的，在 Registry 层拿到地址了需要去调用，调用之前，会进行容错的调用、负载均衡等。LoadBalance是基于上一个环节所拿到的地址，通过LoadBalance 进行 select 之后，这时候得到一个最终的 Invoker （是Dubbo里面的核心机制，可以基于此做远程调用）

此时拿到了 Invoker ，去进行调用，调用的过程中会有一系列的过滤器，形成链式进行过滤，当过滤器链处理完成后会通过协议去处理。

而协议中有个很关键的类叫做 DubboProtocol ，在这里是可以去扩展的，Protocol是一个扩展点，我们在使用的时候在这个扩展点用什么协议取决于 RegistryDirectory 列表中url 中的协议，该url会一直沿着链路传递，直到Protocol来选择要使用的协议，然后进行转发。

转发之后，通过 Exchange 交换层（该层主要负责服务的通信这一块）

Transport 就是交换的协议，主要基于Netty，在协议以后要在 Serialize中做序列化和反序列化，在这之后，会拿到数据进行处理，最终会去调用我们的服务提供者。

而服务提供者这边，其基于Interface，首先会去发布一个服务（exprot），首先也是先从config 去加载服务端的配置，然后把这个配置信息组装成一个url 去添加到注册中心上，这也是我们能够在zk或者nacos上看到的基于服务发布的注册中心地址的一个原因。

然后紧接着到了 MoiniorFactory ，这里面就是服务监控，然后就是 Exporter 发布了，发布是以什么协议发布出去？同样也会根据当前config里所配置的信息，去选择一个对应的协议去发布。

在我们整个框架中，不管是注册中心也好，不管是LoadBalance也好，其都有一个核心的东西叫做扩展点，其基于SPI的机制进行选择（包含三种扩展点：自适应扩展点、激活扩展点、指定名字的扩展点）

最终发布会通过 Netty Server去注册一个监听。

整体串起来的话，就是客户端去发起请求，会通过前面讲的消费者的链路，最终去调用服务发布者的 Implement。

Dubbo模块说明

在这里插入图片描述

Dubbo-bom 版本管理清单
Dubbo-build-tools 版本构建工具
Dubbo-cluster 路由层，包含负载均衡、容错等
Dubbo-Common 提供一些公共包
Dubbo-Compatible 解决兼容问题，解决com.alibaba.dubbo 升级到 org.apache.dubbo所产生的变化，其实就是将一些com.alibaba.dubbo 老的功能单独拎出来
Dubbo-Config 加载配置，然后提供统一的对外配置的类
Dubbo-ConfigCenter 动态配置中心，通过第三方配置中心来统一管理dubbo的配置
Dubbo-Container 容器 Main.main(args) //启动dubbo
启动Dubbo首先加载spring 的配置或者注解, applicationContext=new …();，再去根据配置的信息来启动一个NettServer。
Dubbo-Filter 过滤
Dubbo-Metadata 元数据（配置数据）
Dubbo-Monitor 监控模块（针对服务的调用会产生监控的数据，然后将这些数据上报）
Dubbo-Plugin 插件 auth（授权） qos
Dubbo-Registry 注册中心
Dubbo-Remoting 远程协议支持（包括http、netty）
Dubbo-RPC rpc协议/通信的支持
Dubbo-Serialization 序列化支持