rocketmq发消息流程解析
2021-02-05 16:35:47 13 举报登录查看完整内容
大概对rocketmq的producer发送消息的流程做了一下总结
作者其他创作
大纲/内容
Sync
1.通过ip地址建立channel2.检验channel是否可用3.执行rpc请求前的钩子方法
MQClientAPIImpl.sendMessageASync
MQClientAPIImpl.sendMessage
NettyRemotingAcstract.invokeASyncImpl
MQClientAPIImpl.sendMessageSync
NettyRemotingClient.invokeSync
DefaultMQProductImpl.sendKernelImpl
1.通过netty发送到broker2.包装发送结果作为sendResult返回
NettyRemotingAcstract.invokeSyncImpl
NettyRemotingClient.invokeASync
Async
new DefaultMQProducer().send
mode
收藏
0 条评论
回复 删除
下一页
