Return RocketMqlocal TransactionState.ROLLBACK

今天我们将解决使用RocketMQ事务消息时可能遇到的一个常见问题：如何让其支持多事务消息？ 1. 问题背景 在实际开发中，我们常常会面临多事务消息的场景，例如在DailyMart的订单模块中，用户支付后需要调用库存服务进行库存扣减，而在订单确认收货后需要调用用户服务实现积分赠送。这两个业务逻辑都需要通过事务消息来保证分布式事务。 为了处理这种情况，我们可能会考虑在订单模块中创建两个事务消息监听器，分别用于处理库存扣减和积分赠送的事务处理和事务回查。 @Component @Slf4j //处理订单支付的事务监听器 public class OrderPaidTransactionListener implements RocketMQLocalTransactionListener { @Override public RocketMQLocalTransactionState executeLocalTransaction(Message message, Object o) { ......

下单的过程包括订单创建，还有库存的扣减，为提高系统的性能，将库存放在redis扣减，则会涉及到Mysql和redis之间的数据同步，其中，这个过程还涉及到，必须是订单创建成功才进行库存的扣减操作。其次，还涉及到库存的同步，需要保证订单创建成功和redis里的库存都扣减成功，再将库存数据同步到Mysql，为了实现上述这里情况，可以借助RocketMQ的事务型消息来实现。 流程图如下，这里引入了stocklog，即订单流水表，通过判断stocklog的状态来决定是否commite消息去同步mysql，这里stocklog状态为成功的前提是订单入库和redis库存扣减成功。 对于RocketMQ的事务消息的进一步解释： 在第五步执行成功返回可能因为网络状况卡住，但是stocklog状态已经得到修改 如果返回成功 MQ事务就会commite这条消息 如果没有返回成功 MQ事务会去轮询stocklog有没有被修改 一直轮询发现没有被修改就会回滚这条消息 这条消息Commit后，就会被MQ的消费者消费，对MySQL的实际库存进行更新...

目录 1.