RocketMQ事务消息实现分布式事务数据最终一致性
2022-07-06 22:53:46 9 举报
RocketMQ事务消息实现分布式事务数据最终一致性
作者其他创作
大纲/内容
Commit:投递消息
消息消费者(库存服务)
4.Commit或者Rollback
6.检查本地事务状态,根据transactionId查询transaction_log表,判断本地事务是否执行成功
7.根据事务状态Commit或者Rollback
消息消费者(积分服务)
3.执行本地事务,生成订单,写入transaction_log日志
5.未收到4的确认时,回查事务状态
2.半消息发送成功
本地事务
消息消费者(其他服务)
1.发送事务半消息
下游服务订阅主题,执行相应业务逻辑,保证执行幂等,最终一致性不会回滚数据,失败后可重试,仍然失败则进入死信队列,人工介入处理
Broker服务端
消息生产者
Rollback:不投递消息
0 条评论
下一页