dubbo-go引入RocketMQ作为RPC设计文档1月22

written by Jasondeng1997 on 2022/01/30

dubbo-go引入RocketMQ作为RPC设计文档1月22

设计 实现基于RocketMQ的RPC能力需要实现注册中心模块和protocol模块。

术语

术语统一

术语解释：

• 1 rocketmq的broker作为数据存储组件；
• 2 rocketmq的nameservice作为rocketmq的注册中心与管理中心(如nameservice = dubbo的注册中心)
• 3 dubbo的元数据作为方法参数类型信息方法请求与响应配置信息

1 架构流程

第一步： client发送请求数据到broker 第二步：service从broker拉去请求数据 第三步：当业务处理完成 service把响应数据发送到broker 第四步：client从broker拉去响应数据

• RPC流程

第一步： client发送请求数据到broker
第二步：service从broker拉去请求数据
第三步：当业务处理完成 service把响应数据发送到broker
第四步：client从broker拉去响应数据

• 注册流程

第一步：broker向nameservice注册broker，topic，queue三类信息
第二步：client从nameservice拉去路由信息

PS: 1. 元数据与配置中心可以不做任何改变 2. 可以把元数据注册到nameservice中

• 注册中心设计

1. mock一个注册中心，把路由功能直接交给rocketmq
2. 以nameserver为注册中心
3. 以topic作为注册中心

2 protocol设计

1. protocol模块制定一套标准用于支持各种注册中心 2. 基于dubbo-go的protocol标准开发。

• 总结

  可以实现多套注册中心。

• 注册中心与protocol的开发可以并行开发

目前代码待补充

3 基本功能情况

dubbo的条件路由支持非常困难：

• 1 如果需要支持
• 如果需要支持
• ⅰ. 需要对broker与queue进行标签 ⅱ. server端需要动态感知标签与动态监听 iii. 不建议第一期就支持dubbo的条件路由

tracing的支持

开启RocketMQ的tracing

dubbo与RocketMQ的兼容参考文档1给出的方案是 目前对齐对齐数据

• 2022/1/30，jasondeng，写于上海。