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