一、Dubbo 调用关系说明

1 官网图片地址
image.png

1 Provider

1 暴露服务的服务提供方
2 Protocol 负责提供者和消费者之间协议交互数据
3 Service 真实的业务服务信息 可以理解成接口 和 实现
4 Container Dubbo的运行环境

2 Consumer

1 调用远程服务的服务消费方
2 Protocol 负责提供者和消费者之间协议交互数据
3 Cluster 感知提供者端的列表信息
4 Proxy 可以理解成 提供者的服务调用代理类 由它接管 Consumer中的接口调用逻辑

3 Registry

注册中心,用于作为服务发现和路由配置等工作,提供者和消费者都会在这里进行注册

4 Monitor

用于提供者和消费者中的数据统计,比如调用频次,成功失败次数等信息

5 启动和执行流程

1 提供者端启动 容器负责把Service信息加载 并通过Protocol 注册到注册中心
2 消费者端启动 通过监听提供者列表来感知提供者信息,并在提供者发生改变时通过注册中心及时通知消费端
3 消费方发起 请求通过Proxy模块利用Cluster模块来选择真实的要发送给的提供者信息交由Consumer
4 Protocol 把信息发送给提供者
5 提供者同样需要通过 Protocol 模块来处理消费者的信息
6 最后由真正的服务提供者 Service 来进行处理

二、Dubbo协议 各层介绍

image.png

1 Business 业务逻辑层

1 service

业务层:包括我们的业务代码。比如接口实现类直接面向开发者 RPC层远程过程调用层。

2 RPC层 远程过程调用层

1 config

配置层:对外提供配置以ServiceConfig ReferenceConfig 为核心 可以直接初始化配置也可以解析配置文件生成

2 proxy

服务代理层 :无论是生产者 还是消费者框架都会产生一个代理类,整个过程对上层透明。就是业务层对远程调用无感

3 registry

注册中心层:封装服务地址的注册与发现以服务的URL为中心

4 cluster

路由层 :(集群容错层) 提供了多个提供者的路由和负载均衡 并且它桥接注册中心以 Invoker为核心

5 monitor

监控层: RPC调用相关的信息。如 调用次数 成功失败的情况 调用时间等 在这一层完成

6 protocol

远程调用层:封装RPC调用 无论是服务的暴露 。还是服务的引用都是在Protocol中作为主功能入口负责Invoker的整个生命周期 Dubbo中所有的模型都向Invoker靠拢

3 Remoting层 远程数据传输层

1 exchange

信息交换层: 封装请求和响应的模式 如把请求由同步,转换成异步

2 transport

网络传输层:统一网络传输的接口 。比如 netty 和 mina 统一为一个网络传输接口

3 serialize

数据序列化层: 负责管理整个框架中的数据传输的序列化和反序列化

三、调用链路

image.png

1. 第一步:

消费者通过Interface进行方法调用,统一交由消费者端的 Proxy 通过ProxyFactory 来进行代理对象的创建(使用到了 jdk javassist技术)

2.第二步:

Filter 这个模块做一个统一的过滤请求

3.第三步

Invoker调用逻辑
1)通过Directory 去配置中新读取信息 最终通过list方法获取所有的Invoker
2)通过Cluster模块 根据选择的具体路由规则 来选取Invoker列表
3)通过LoadBalance模块 根据负载均衡策略 选择一个具体的Invoker 来处理我们的请求
4)如果执行中出现错误 并且Consumer阶段配置了重试机制 则会重新尝试执行

4 第四步

Filter 进行执行功能的前后封装 Invoker 选择具体的执行协议。

5 第五步

客户端 进行编码和序列化 然后发送数据

6 第六步

请求到达Consumer中的 Server 在这里进行 反编码 和 反序列化的接收数据

7 第七步

使用Exporter选择执行器

8 第八步

Filter 进行一个提供者端的过滤 到达 Invoker 执行器

9 第九步

通过Invoker 调用接口的具体实现 ,然后返回。