RocketMq消息发送流程

消息发送使用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