RocketMQ解决分布式事务思路

基本实现思路:

  1. 生产者(发送方)投递事务消息到Broker中,设置该消息为半消息 不可以被消费;
  2. 开始执行我们的本地事务,将本地事务执行的结果(回滚或者提交)发送给Broker
  3. Broker获取回滚或者提交,如果是回滚的情况则删除该消息、如果是提交的话,该消息就可以被消费者消费;
  4. Broker如果没有及时的获取发送方本地事务结果的话,会主动查询本地事务结果。

 

 

RocketMQ解决分布式事务思路