美文网首页
RocketMq消息发送流程

RocketMq消息发送流程

作者: saiyin_51fb | 来源:发表于2020-04-28 19:40 被阅读0次

消息发送使用send方法我们看一下消息发送的整体的流程


image.png

默认超时时间 3S


image.png
RocketMq 支持三种消息发送方式
image.png

获取topic 路由


image.png

更新nameServer


image.png
使用RemotingCommand netty 底层通讯的
image.png

netty 通讯部分 remoting 模块详细介绍
代码中全局搜索GET_ROUTEINTO_BY_TOPIC 关键字找到对应方法处理的位置


image.png
找到topic 路由后根据topic 找到对应的队列发送
image.png
消息发送
image.png
消息发送有两个协议版本
image.png
根据消息发送事件找到对应的事件注册模块上
image.png

使用netty 发送消息


image.png

处理消息发送的逻辑


image.png

相关文章

网友评论

      本文标题:RocketMq消息发送流程

      本文链接:https://www.haomeiwen.com/subject/tovbwhtx.html