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 条评论
下一页