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
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。