RocketMQ--Netty底层框架解析

it2025-07-10  10

框架

实现接口

RemotingClient

=========================================================================================================

=========================================================================================================

RemotingServer

NettyRemotingServer

NettyRemotingAbstract

真正实现发送消息的机制

编解码

消息长度: 四个字节存储,占用一个int类型字节

序列化类型&&头部长度: 表示序列化类型,后面表示真正消息头的长度

消息头数据: 序列化的数据,采用fastjson形式

消息主体数据:

RemotingCommand

=======================================================================================================

NettyRemotingClient

NettyDecoder

最新回复(0)