dubbo3.x消费端源码浅析以及Triple协议的实现

前言

本篇文章以dubbo最新版本dubbo-3.0.5进行分析

首先跑一下dubbo-demo-spring-boot的示例，直观感受一下查看官方文档，了解dubbo3.x的变更内容（主要看了服务注册发现、Triple协议）对Dubbo消费端源码进行了分析总结逐步跟代码，找到Dubbo对Triple协议实现的地方（具体实现逻辑暂未分析）对grpc进行简单介绍并编写了demo感受了一下 Dubbo整体介绍

服务发现

# application.properties
dubbo
 registry
  address: zookeeper://127.0.0.1:2181

Dubbo消费端源码分析

Triple协议

dubbo 3.x选择兼容gRPC，以HTTP2作为传输层构建新的协议，也就是 Triple
1.1 这行描述性的文字显得冷冰冰？那dubbo3.x是怎么实现的？如果要我去实现，怎么去实现？

以dubbo-3.0.5分支的dubbo-demo-triple模块为例，启动ApiProvider服务提供者，一步一步跟代码
2.1 从ApiProvider启动发现设置协议的地方（红色标记），有设置就有使用的地方（顺藤摸瓜）

2.2 在获取协议配置的地方打上断点，观察在哪里获取配置，然后获取之后干嘛？
（1）发现在ConfigManager#refreshAll时会获取协议配置，并对ProtocolConfig属性进行赋值
（2）再打断点观察ProtocolConfig赋值属性（name、port）在哪里被调用
2.3 排除一些校验之外，最终发现真正调用的地方在ServiceConfig#doExportUrlsFor1Protocol
（1）将协议绑定到url
（2）把url暴露出去（因为协议在url中，所以一直观察url的使用，最终会跟到ServiceConfig#doExportUrl）

（3）这里dubbo提供扩展点，找到Triple协议的扩展TripleProtocol#export（重点就在PortUnificationExchanger.bind(invoker.getUrl())）

重点关注PortUnificationExchanger绑定Url
3.1 按照地址的维度（ip+port）开启服务PortUnificationServer

3.2 关注PortUnificationServer是如何绑定的（PortUnificationServer#doOpen）
（1）看下面的截图，标准的netty服务端写法，里面包含关于协议的handler:PortUnificationServerHandler

（2）服务端在接受请求，调用PortUnificationServerHandler#decode进行解码
（3）调用demo的ApiConsumer发现在解码后，会调用TripleHttp2Protocol#configServerPipeline（这里面的实现印证了上面冷冰冰的描述）

gRPC介绍 proto文件定义服务

// 服务接口
service HelloService {
	rpc SayHello (HelloRequest) returns (HelloResponse);
}
// 定义请求类型
message HelloRequest {
  string greeting = 1;
}
// 定义返回类型
message HelloResponse {
  string reply = 1;
}

生成客户端和服务端代码


  io.grpc
  grpc-netty-shaded
  1.43.1
  runtime


  io.grpc
  grpc-protobuf
  1.43.1


  io.grpc
  grpc-stub
  1.43.1

 
  org.apache.tomcat
  annotations-api
  6.0.53
  provided


  
    
      kr.motd.maven
      os-maven-plugin
      1.6.2
    
  
  
    
      org.xolstice.maven.plugins
      protobuf-maven-plugin
      0.6.1
      
        com.google.protobuf:protoc:3.19.1:exe:${os.detected.classifier}
        grpc-java
        io.grpc:protoc-gen-grpc-java:1.43.1:exe:${os.detected.classifier}
      
      
        
          
            compile
            compile-custom

束语

本篇更偏向是知识点的梳理，里面具体的实现待分析。等找到合适的场景，自定义RPC协议，带着实际场景去学习

dubbo3.x消费端源码浅析以及Triple协议的实现

大数据系统相关栏目本月热门文章