RocketMQ顺序消息流程
2025-02-12 19:57:50 0 举报RocketMQ顺序消息流程
作者其他创作
大纲/内容
TagA
推送
一
key3
DefaultMQProducerImpl
NamingServer
构建消息请求
TagD
key2
付款
queueId:1
这里选择的队列会重新回调之前自定义的消息队列选择方法
完成
①
③
queueId:2
查询TopicPublishInfo信息（先从本地缓存中找，找不到从nameServer查询，然后缓存到本地中）
创建
orderId=15103111039
消费顺序
send方法
MQClientAPIImpl
orderId=15103117235
同步发送消息？
key5
key9
一二三
key6
queueId:3
TagC
key1
选择一个消息队列selectOneMessageQueue
NettyRemotingClient
invokeSync
key4
key8
首先调用消息队列选择方法，得到一个消息队列
检察服务状态是否正常
②
sendMessageSync
三
key0
④
invokeMessageQueueSelector方法
最大三次重试次数
线程二
线程一
orderId=15103111065
真正发送消息sendKernelImpl
源码中生产者发送顺序消息com.tuling.order.rocketmq.ordermessage.example02.Producer
DefaultMQProducer
key7
①②③④
font color=\"#e74f4c\
二
0 条评论
下一页
