spark基础知识整理

消息在被 rpc server 收到以后,经过了怎么样的转换最终到了 endpoint?

把表示消息原始字节的 ByteBuffer 类型的对象 message 封装成 DataInputStream

从 DataInputStream 中取出 发送者地址 senderAddress 以及 endpoint 地址 endpointAddress

使用 endpointAddress 地址,构造出表示 endpoint 的 NettyRpcEndpointRef 对象

从剩余的字节中反序列化出具体的消息对象

最后构造一个包含具体消息对象 以及发送者信息 和 endpoint 对象的 RequestMessage 对象


用于实际处理 rpc 消息的 NettyRpcHandler,收到消息时候,传入的 TransportClient 有什么用?

rpc handler 追踪所有与它通讯的 客户端实例,在给客户端的 endpoint 发送消息的时候知道使用哪个实例

rpc 事件的发送是在每个连接之上的,

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容