Spring 事务提交后发送 MQ 消息的最佳实践

在 Spring 应用中，我们经常需要将一些业务逻辑放到事务中执行，并在事务提交成功后发送消息到消息队列（MQ）。例如，以下代码展示了在事务提交成功后发送 MQ 消息的常见做法：

// 发送消息到 MQ
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
    @Override
    public void afterCommit() {
        // 发送 mq 更新 es 库存标志
        for (Long drugId : drugIdList) {
            DrugChangeMessage drugChangeMessage = new DrugChangeMessage();
            drugChangeMessage.setDrugId(drugId);
            drugChangeMessage.setStoreId(order.getStoreId());
            drugChangeMessage.setChangeType(5);
            drugChangeMessage.setMerchantId(Long.parseLong(merchantId));
            drugChangeMessage.setEnterpriseId(Long.parseLong(enterpriseId));
            drugChangeMessage.setPlatformId(Long.parseLong(platformId));
            drugProducer.sendDrugChangeMsg(drugChangeMessage);
        }
    }
});

然而，在实际开发中，我们可能会遇到 MQ 消息在事务提交成功前就被消费的情况，这将导致数据不一致的问题。

问题分析

如果 MQ 消息在事务提交成功前就被消费了，可能有以下几种情况：

MQ 消费者在接收到消息后立即进行消费，而事务提交的过程较慢，导致消息在事务提交前就被消费了。
MQ 消费者使用的是异步消费的方式，即消息接收和处理是分开的。如果在消息接收后，但在事务提交前，消费者已经开始处理消息，那么消息可能会在事务提交前被消费。
MQ 消费者和事务提交是并行执行的，即消息消费和事务提交是同时进行的。在这种情况下，如果消息消费速度较快，可能会在事务提交前就消费掉消息。

解决方法

为了确保消息在事务提交成功后再进行消费，可以采取以下措施：

使用同步消费方式，即消息接收和处理是同步进行的，保证在事务提交后再进行消息处理。 这种方式可以确保消息只有在事务提交成功后才能被消费。
使用分布式事务管理器，如 Spring 的分布式事务管理器，确保事务的原子性和一致性。 这样可以在事务提交成功后再进行消息发送。
提高事务提交的速度，减少事务提交的时间消耗，确保在消息消费前事务已经提交成功。 可以通过优化数据库操作、减少事务隔离级别等方式来提升事务提交速度。

总结

通过以上措施，可以确保消息在事务提交成功后再进行消费，避免在事务提交前消息被消费的情况发生，从而保证数据的一致性。在实际开发中，需要根据具体的场景选择合适的解决方案。