2PC Prepare阶段连接丢失时如何确保JMS消息回滚？

结合你的技术栈（Java 8、Spring Boot 2.3.12、Narayana 5.11.3、IBM MQ 9.2.5）和复现场景，咱们先拆解问题根源，再一步步给出具体的解决办法：

问题根源梳理 #

你遇到的核心矛盾是：XA事务的Prepare阶段连接断开后，MQ的消息被预取锁定，但既没回滚到原队列，也没进入回退/死信队列。这主要源于两个关键点：

1. IBM MQ的XA分支处理逻辑：当Prepare阶段连接中断，MQ队列管理器在心跳超时（HBINT）后会清理连接，但不会自动回滚未完成的XA事务分支——因为它没收到事务管理器的明确Rollback指令。
2. Narayana的事务恢复机制未生效：默认情况下Narayana会自动恢复未完成的XA事务，但如果配置缺失或日志存储异常，就无法触发对MQ分支的回滚操作。

适配你技术栈的解决方案 #

1. 确保Narayana的事务恢复机制正确配置 #

Narayana作为XA事务管理器，其自动恢复是解决这类问题的核心。检查你的application.properties配置：

# 显式启用事务恢复（默认已开启，但建议显式声明）
narayana.recovery.enabled=true
# 恢复间隔（每2分钟检查一次未完成事务，可按需调整）
narayana.recovery.delay=120
# 事务日志存储路径（必须持久化，容器环境要映射到持久卷）
narayana.log.dir=/path/to/persistent/narayana-logs

另外，要确保IBM MQ的XA连接工厂被正确注册到Narayana的恢复器中。如果使用Spring Boot自动配置，只要你用的是MQXAQueueConnectionFactory，Spring会自动把它绑定到Narayana的JTA事务上下文。

2. 调整IBM MQ的XA相关配置 #

通过MQ控制台或runmqsc命令修改队列管理器参数，让它配合事务恢复：

• 执行runmqsc <你的队列管理器名>，输入以下命令：

  # 设置XA分支重试次数（默认0，建议设为5）
  ALTER QMGR XARETRYCOUNT(5)
  # 设置XA分支重试间隔（单位秒，建议设为60）
  ALTER QMGR XARETRYINTERVAL(60)
  # 设置主动通知事务管理器的间隔（单位秒，建议设为30）
  ALTER QMGR UNSOLICITEDMSGINT(30)
  

• 同时，确保你的MQ连接工厂开启重连选项：

  @Bean
  public MQXAQueueConnectionFactory xaQueueConnectionFactory() {
      MQXAQueueConnectionFactory factory = new MQXAQueueConnectionFactory();
      // 配置MQ地址、队列管理器等基础参数
      factory.setHostName("your-mq-host");
      factory.setQueueManager("your-qmgr");
      // 开启自动重连，确保恢复时能重新连接MQ
      factory.setReconnectOptions(MQConstants.RECONNECT | MQConstants.RECONNECT_Q_MGR);
      return factory;
  }
  

3. 修正Spring JMS的事务配置 #

避免本地Session事务干扰XA事务，确保JMS容器使用Narayana的JTA事务管理器：

@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactory(MQXAQueueConnectionFactory xaConnectionFactory, JtaTransactionManager jtaTransactionManager) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(xaConnectionFactory);
    // 绑定Narayana的JTA事务管理器
    factory.setTransactionManager(jtaTransactionManager);
    // 关键：XA事务下禁用本地Session事务
    factory.setSessionTransacted(false);
    // 确认模式由JTA事务控制
    factory.setSessionAcknowledgeMode(Session.SESSION_TRANSACTED);
    return factory;
}

同时，你的消息监听方法要加上@Transactional注解，确保整个消费过程处于XA事务上下文：

@JmsListener(destination = "队列X")
@Transactional
public void handleMessage(Message message) {
    // 业务逻辑处理
}

4. 手动触发事务恢复（调试用） #

如果自动恢复未及时生效，可以手动触发Narayana的恢复：

• 找到Narayana安装包的bin目录，执行./recovery.sh（Linux）或recovery.bat（Windows）；
• 或者在代码中注入RecoveryManager手动调用：

  @Autowired
  private RecoveryManager recoveryManager;
  
  // 触发恢复
  public void triggerRecovery() {
      recoveryManager.recover();
  }
  

5. 手动清理MQ的未完成XA分支（应急用） #

如果消息长期处于“失踪”状态，可以用MQ命令行工具查看并回滚未完成的XA事务：

1. 执行runmqsc <你的队列管理器名>；
2. 输入DISPLAY XACT查看所有未完成的XA事务分支；
3. 对目标分支执行回滚：RESOLVE XACT(<xid>) ACTION(ROLLBACK)，其中<xid>是事务分支的ID。

关键注意事项 #

• Narayana日志必须持久化：如果是容器部署，一定要把narayana.log.dir映射到持久卷，否则容器重启后事务日志丢失，无法恢复未完成的事务；
• 必须使用XA连接工厂：确保你的MQ连接工厂是MQXAQueueConnectionFactory，而非普通的MQQueueConnectionFactory，否则无法参与XA事务；
• 避免混合事务模式：不要同时启用本地Session事务和XA事务，否则会导致事务控制混乱。

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