二：NettyRemotingServer Remoting 服务端实现 broker 启动初始化 NettyRemotingServer ， 向 netty 注册 handler NettyEncoder 协议编码器，将 RemotingCommand 转换为字节，给 netty 传输 NettyDecoder 协议解码器， 将 netty 接收的输入流，转换成 RemotingCommand Nett , sendMessageExecutor) 三：NettyRemotingClient 向 netty 注册 handler NettyEncoder 协议编码器，将 RemotingCommand 转换为字节，给 netty 传输 NettyDecoder 协议解码器， 将 netty 接收的输入流，转换成 RemotingCommand N 四：底层传输协议 RocketMq 服务器与客户端通过传递 RemotingCommand 来交互，通过 NettyDecoder， NettyEncoder 对 RemotingCommand 进行协议的编码与解码 协议格式

1 2

相关界面上的消费 TPS 主要来自 examineConsumeStats 方法，该方法我就不再继续深入，我们只需找到 该方法向 broker 发送的请求编码，然后根据该请求编码找到 broker 的处理逻辑即可， 最后跟踪发送的请求编码为：RequestCode.GET_CONSUME_STATS。 GET_CONSUME_STATS 命令在 broker 的处理逻辑如下： 本文来自『中