Spring @Transactional注解事务问题：IBM MQ消息无法回滚

问题根源 #

默认情况下，JmsTemplate.send() 操作会在独立的JMS会话中执行，不会自动加入到Spring声明式事务（如数据库事务）的上下文里。当数据库事务因异常回滚时，MQ消息已经被提交发送，无法撤销，从而导致数据不一致。

方案1：使用XA分布式事务（跨资源事务一致性） #

如果业务同时涉及数据库操作和MQ消息发送，需要通过XA事务实现跨资源的原子性：

• 配置XA资源：
  1. 为IBM MQ配置XA连接工厂（需确保MQ队列管理器开启XA支持），同时为数据库配置XA数据源。
  2. 配置Spring的JtaTransactionManager（或对应JTA实现的事务管理器，如Atomikos），将XA连接工厂和XA数据源注册到该管理器中。
• 代码调整：
  在事务方法上指定XA事务管理器：

  @Transactional(transactionManager = "jtaTransactionManager")
  public void businessMethod() {
      methodA(); // 数据库操作
      methodB(); // 数据库操作
      methodC(); // 调用JmsTemplate.send()
  }
  

  确保JmsTemplate使用XA连接工厂，这样发送操作会加入到XA事务中，当事务回滚时，MQ消息会被撤销。

方案2：本地事务补偿机制（轻量级替代方案） #

如果不想引入XA事务的性能开销，可以采用先持久化、后发送的补偿方案：

• 步骤1：新增消息日志表
  在数据库中创建消息日志表，字段包含：id、message_content、status（待发送/已发送/发送失败）、retry_count、create_time等。
• 步骤2：事务内持久化消息
  在methodC中，不直接发送MQ消息，而是将消息内容插入到消息日志表：

  public void methodC(String message) {
      messageLogMapper.insert(new MessageLog(null, message, "PENDING", 0, new Date()));
  }
  

• 步骤3：事务提交后异步发送
  使用Spring的@TransactionalEventListener监听事务提交事件，在事务成功提交后发送消息：

  @Component
  public class MessageSenderListener {
      @Autowired
      private JmsTemplate jmsTemplate;
      @Autowired
      private MessageLogMapper messageLogMapper;
  
      @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
      public void sendMessageAfterCommit(MessageLogEvent event) {
          try {
              jmsTemplate.send("queue-name", session -> session.createTextMessage(event.getMessageContent()));
              messageLogMapper.updateStatus(event.getLogId(), "SUCCESS");
          } catch (Exception e) {
              messageLogMapper.updateStatus(event.getLogId(), "FAILED");
              // 可触发重试逻辑，比如定时任务扫描失败消息
          }
      }
  }
  

  （注：MessageLogEvent是自定义事件类，在插入消息日志后发布该事件）
• 步骤4：重试机制
  编写定时任务，定期扫描状态为FAILED或PENDING且超过重试时间的消息，重新发送，保证消息最终一致性。

方案3：JMS本地事务绑定（仅单资源场景） #

如果业务中只有MQ操作，没有数据库事务，可以直接让JMS操作加入本地事务：

• 配置JmsTemplate的sessionTransacted属性为true：

  <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
      <property name="connectionFactory" ref="mqConnectionFactory"/>
      <property name="sessionTransacted" value="true"/>
  </bean>
  

  或者在Java配置中：

  @Bean
  public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory) {
      JmsTemplate template = new JmsTemplate(connectionFactory);
      template.setSessionTransacted(true);
      return template;
  }
  

  此时，JmsTemplate.send()会在JMS事务中执行，当Spring事务回滚时，JMS事务也会回滚，消息不会发送。

内容的提问来源于stack exchange，提问作者Priyank