AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
RocketMQ 发送事务消息的整体实现流程
2023-07-11 22:19:41
6
举报
分享方式
免费使用
Rocket 发送事务消息的整体流程
RocketMQ
模版推荐
作者其他创作
大纲/内容
TransactionMQProducer
Broker
RMQ_SYS_TRANS_OP_HALF_TOPIC
Producer
开启异步线程进行回查
3. 执行本地事务executeLocalTransaction()
1.prepare 发送 half message
DB
4. 提交/回滚事务
A. 获取队列
接收生产者事务消息
C. 根据回查结果确定是 Commit还是 Rollback
TransactionListener
获取队列拉取消息判断是否进行回查更新消费进度
2. 返回 ack
RMQ_SYS_TRANS_HALF_TOPIC
事务处理类
6. deletePrepareMessage() 其实就是把 HALF 中的消息添加到 OP 中，表示已处理
SendMessageProcessor
EndTransactionProcessor
事务消息原本的 Topic
B.检查本地事务checkLocalTransaction
收藏
立即使用
RocketMQ 发送事务消息的整体实现流程
收藏
立即使用
SpringBoot的自动装配流程
收藏
立即使用
MyBatis的执行流程
收藏
立即使用
Netty的线程模型
木易 ฅ
职业：Java开发
去主页
Collect
Get Started
RocketMQ消息类型（延迟消息/事务消息）
Collect
Get Started
发送消息
Collect
Get Started
发送消息
Collect
Get Started
RocketMQ事务的处理
评论
0
条评论
下一页
Document
