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

默认超时时间 3S

RocketMq 支持三种消息发送方式

获取topic 路由

更新nameServer

使用RemotingCommand netty 底层通讯的

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

找到topic 路由后根据topic 找到对应的队列发送

消息发送

消息发送有两个协议版本

根据消息发送事件找到对应的事件注册模块上

使用netty 发送消息

处理消息发送的逻辑

网友评论