Naocs 2.1.0 grpcServer启动源码剖析
2025-04-06 10:30:04 0 举报123
作者其他创作
大纲/内容
String type = grpcRequest.getMetadata().getType();
Payload grpcRequest，Payload在接口文件nacos_grpc_service.proto里定义
NettyServer
netty服务端的逻辑
客户端与服务端的连接对象
final String connectionId = CONTEXT_KEY_CONN_ID.get();
font color=\"#ed77b6\
server = ServerBuilder.forPort(getServicePort())
BaseRpcServer.start()
RequestHandlerRegistry.onApplicationEvent
这边是服务端grpc处理请求和连接逻辑
服务端grpc处理请求逻辑
下面是服务端grpc启动逻辑
message Payload { Metadata metadata = 2; google.protobuf.Any body = 3;}
RequestHandler requestHandler = requestHandlerRegistry.getByRequestType(type);
HealthCheckRequestHandler
InstanceRequestHandler
SubscribeServiceRequestHandler
startServer();
服务发现订阅的处理器
根据客户端请求类型找到对应handler
服务注册的处理器，看服务注册的源码
接口定义文件nacos_grpc_service.proto
ts.start(listener)
return registryHandlers.get(requestType);
clientConnectionEventListener.clientConnected(connection);
ConnectionBasedClientManager
clientFactory.newClient
服务健康监测的处理器
for (RequestHandler requestHandler : values)
server.start();
拿到8848+1000的端口号，作为grpc的端口号，跟客户端那边请求的端口号一致
服务端grpc处理连接逻辑
connectionManager.register(font color=\"#ed77b6\
收藏
收藏
0 条评论
下一页
