RocketMQ分布式事务
2021-04-21 09:50:46 0 举报
登录查看完整内容
RocketMQ分布式事务流程图
作者其他创作
大纲/内容
发送confirm消息
B系统
假如说A系统发送confirm消息失败了，消息停留在prepared阶段，RocketMQ自动轮询所有prepared状态消息
A系统
发送prepared消息，如果本地事务失败，就会发送消息回滚刚才那个prepare消息
redis
数据库
B系统一定要保证自己的幂等性可以在redis记录一个标识来说明自己已经处理过该消息了也可以在zookeeper中，创建一个node，表示该消息已经处理过了，如果重复消息过来，创建node会报错
RocketMQ
回调A系统的一个接口，问你：这个消息是回滚还是重新发送一个确认消息？
一旦A系统发送confirm消息，MQ就会让B系统消费到这条消息
0 条评论
回复 删除
下一页
