判断请求是否为单向(OneWay)
获取信号量
根据opaque得到ResponseFuture
RocketMQ Remoting异步通信流程
设置opaque至Response中并发送至Client端
根据业务编码获取对应的处理器
组装RemotingCommand并生成回调
业务处理器执行后得到Response结果
NettyRemotingClient
NettyClientHandler
调用Netty的channel的writeAndFlush方法发送
NettyRemotingServer
读取Netty收到的消息并做处理
提交至线程池
将opaque存入ResponseFuture响应对象中
Thread
processMessageReceived方法处理
NettyServerHandler
根据Addr创建通信的Channel
执行回调方法