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