Spring Boot 事务中使用 MQ 修改库存：防止事务未提交导致数据不一致

您可以通过以下步骤来实现带有事务的订单方法调用 MQ 修改库存，并在事务未提交时先消费 MQ 的需求：

1. 在 Spring Boot 应用程序中配置 MQ 的连接和配置。
2. 创建一个带有事务注解的订单方法，例如使用@Transactional注解。
3. 在订单方法中修改库存，并将修改的库存信息发送到 MQ。
4. 创建一个继承ApplicationListener<TransactionPhaseExecutionEvent>接口的事务事件监听器，例如TransactionEventListener。
5. 在监听器中实现onApplicationEvent方法，该方法会在事务执行阶段触发。
6. 在onApplicationEvent方法中，通过TransactionPhaseExecutionEvent对象获取当前事务的执行阶段。
7. 如果当前执行阶段是AFTER_COMMIT，表示事务已经提交，可以消费 MQ 消息。
8. 如果当前执行阶段是BEFORE_COMMIT，表示事务即将提交，可以在此处进行 MQ 消费，但需要注意事务提交前的 MQ 消费失败会导致数据不一致。
9. 如果当前执行阶段是AFTER_ROLLBACK，表示事务已经回滚，不需要进行 MQ 消费。

下面是示例代码：

@Service
public class OrderService {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Transactional
    public void createOrder(Order order) {
        // 修改库存
        // ...

        // 发送 MQ 消息
        rabbitTemplate.convertAndSend('exchange', 'routingKey', order);
    }
}

@Component
public class TransactionEventListener implements ApplicationListener<TransactionPhaseExecutionEvent> {

    @Override
    public void onApplicationEvent(TransactionPhaseExecutionEvent event) {
        TransactionPhase phase = event.getPhase();
        if (phase == TransactionPhase.AFTER_COMMIT) {
            // 事务已提交，可以消费 MQ 消息
            Order order = event.getArgs()[0]; // 获取订单参数
            // 消费 MQ 消息
            // ...
        } else if (phase == TransactionPhase.BEFORE_COMMIT) {
            // 事务即将提交，可以在此处进行 MQ 消费
            Order order = event.getArgs()[0]; // 获取订单参数
            // 消费 MQ 消息
            // ...
        } else if (phase == TransactionPhase.AFTER_ROLLBACK) {
            // 事务已回滚，不需要进行 MQ 消费
        }
    }
}

注意事项：

• 在事务提交前进行 MQ 消费存在风险，如果 MQ 消费失败，会导致数据不一致。可以考虑在事务提交后再进行 MQ 消费。
• 在 MQ 消费过程中，如果需要传递参数，可以将参数封装到订单对象中，并在消费端获取订单对象进行处理。