消息在被 rpc server 收到以后,经过了怎么样的转换最终到了 endpoint?
把表示消息原始字节的 ByteBuffer 类型的对象 message 封装成 DataInputStream
从 DataInputStream 中取出 发送者地址 senderAddress 以及 endpoint 地址 endpointAddress
使用 endpointAddress 地址,构造出表示 endpoint 的 NettyRpcEndpointRef 对象
从剩余的字节中反序列化出具体的消息对象
最后构造一个包含具体消息对象 以及发送者信息 和 endpoint 对象的 RequestMessage 对象
用于实际处理 rpc 消息的 NettyRpcHandler,收到消息时候,传入的 TransportClient 有什么用?
rpc handler 追踪所有与它通讯的 客户端实例,在给客户端的 endpoint 发送消息的时候知道使用哪个实例
rpc 事件的发送是在每个连接之上的,