RocketMQ Remoting异步通信流程
2019-12-26 13:12:15 0 举报RocketMQ Remoting异步通信流程
作者其他创作
大纲/内容
判断请求是否为单向（OneWay）
获取信号量
根据opaque得到ResponseFuture
RocketMQ Remoting异步通信流程
设置opaque至Response中并发送至Client端
根据业务编码获取对应的处理器
组装RemotingCommand并生成回调
业务处理器执行后得到Response结果
NettyRemotingClient
NettyClientHandler
调用Netty的channel的writeAndFlush方法发送
NettyRemotingServer
读取Netty收到的消息并做处理
提交至线程池
将opaque存入ResponseFuture响应对象中
Thread
processMessageReceived方法处理
NettyServerHandler
根据Addr创建通信的Channel
执行回调方法
0 条评论
下一页
