在 spring 应用中使用 @jmslistener 消费 ibm mq 消息时，仅配置 jmstransactionmanager 无法保证数据库操作与 jms 消息处理的原子性；必须引入 jta 事务管理器（如 atomikos 或 bitronix）统一协调跨资源事务，才能实现消息回滚与数据库回滚的强一致性。
默认情况下，@Transactional 与 JmsTransactionManager 仅作用于 JMS 层——它能回滚 MQ 消息（例如将未确认的消息重新入队），但对 JDBC/ORM（如 JPA/Hibernate）操作完全无感知。这是因为 Spring 的单资源事务管理器（如 DataSourceTransactionManager 或 JmsTransactionManager）彼此隔离，无法形成跨数据源的原子事务。您当前的配置中，jmsTemplate.setSessionTransacted(true) 启用了本地 JMS 会话事务，而 @Transactional 若未显式指定 transactionManager，则可能默认绑定到数据源事务管理器，导致两者实际运行在两个独立事务上下文中——这正是数据库不回滚的根本原因。
要实现“消息消费 + 数据库写入 + 响应发送”三者的一致性（即任一环节失败，全部回滚），必须升级为 JTA（Java Transaction API）分布式事务。JTA 由事务管理器（如 Atomikos、Narayana 或 WebSphere Liberty 内置的 JTA 实现）驱动，支持 XA 协议，可协调多个 XA-capable 资源（如 IBM MQ 的 XA 连接工厂、支持 XA 的 JDBC 数据源）在一个全局事务中提交或回滚。
✅ 正确配置步骤（以 Atomikos 为例）
-
添加依赖（Maven）
org.springframework.boot spring-boot-starter-jta-atomikos com.ibm.mq mq-jms-spring-boot-starter 3.2.0 -
配置 XA 数据源与 XA MQ 连接工厂
@Configuration public class JtaConfig { @Bean(initMethod = "init", destroyMethod = "close") @ConfigurationProperties("spring.jta.atomikos.properties") public UserTransactionManager userTransactionManager() { UserTransactionManager manager = new UserTransactionManager(); manager.setForceShutdown(false); return manager; } @Bean @DependsOn("userTransactionManager") public UserTransaction userTransaction() throws Throwable { UserTransactionImp ut = new UserTransactionImp(); ut.setTransactionTimeout(300); return ut; } @Bean @Primary public PlatformTransactionManager transactionManager() throws Throwable { JtaTransactionManager jta = new JtaTransactionManager(); jta.setUserTransaction(userTransaction()); jta.setTransactionManager(userTransactionManager()); return jta; } // ✅ 使用 XA-aware 的 IBM MQ ConnectionFactory（关键！） @Bean public JmsConnectionFactoryWrapper xaMQConnectionFactory() { // 注意：需通过 IBM MQ 提供的 XAConnectionFactory 创建 // 示例（实际请按 MQ v9+ 文档配置）： com.ibm.mq.jms.MQXAConnectionFactory cf = new com.ibm.mq.jms.MQXAConnectionFactory(); cf.setHostName("mq-host"); cf.setPort(1414); cf.setQueueManager("QM1"); cf.setChannel("DEV.APP.SVRCONN"); cf.setTransportType(WMQConstants.WMQ_CM_CLIENT); return new JmsConnectionFactoryWrapper(cf); // 封装为 Spring XA 兼容 Bean } // ✅ XA 数据源（以 HikariCP + PostgreSQL 为例） @Bean @ConfigurationProperties("spring.datasource.xa") public DataSource dataSource() { return new AtomikosDataSourceBean(); } } -
更新 Listener：显式使用 JTA 事务管理器
@Service public class TestListener { @Autowired private OrderRepository orderRepository; @Autowired private JmsTemplate jmsTemplate; @JmsListener( containerFactory = "jmsListenerContainerFactory", destination = "ibm.mq.request" ) @Transactional // ✅ 默认使用 JtaTransactionManager（因已设为 @Primary） public void receive(String message) { // 1. 解析 & 业务逻辑 Order order = parseOrder(message); // 2. 持久化（参与 JTA 全局事务） orderRepository.save(order); // 3. 发送响应（同样参与同一 JTA 事务） jmsTemplate.convertAndSend("ibm.mq.response", buildResponse(order)); // 若此处抛出 RuntimeException → 整个 JTA 事务回滚： // - DB insert 撤销 // - MQ request 消息未确认（重回队列） // - MQ response 消息不发送 } } -
确保 JmsListenerContainerFactory 支持 XA
@Bean public DefaultJmsListenerContainerFactory jmsListenerContainerFactory( @Qualifier("xaMQConnectionFactory") ConnectionFactory connectionFactory, PlatformTransactionManager transactionManager) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); factory.setTransactionManager(transactionManager); // ✅ 绑定 JTA TM factory.setSessionTransacted(true); // 必须为 true，否则不触发 XA 分支注册 factory.setConcurrency("1-5"); return factory; }
⚠️ 关键注意事项
- XA 资源要求：IBM MQ 必须启用 XA（需配置 CHANNEL 为 SVRCONN 类型并开启 CHLAUTH 规则允许 XA）、数据库驱动需支持 XA（如 postgresql-42.6.0.jar 提供 XADataSource）。
- 不要混用本地事务：移除 @Transactional 上对 JmsTransactionManager 的引用；禁用 jmsTemplate.setSessionTransacted(true) 以外的本地事务配置。
- 异常类型：仅 RuntimeException 及其子类（或显式声明 @Transactional(rollbackFor = ...)）触发回滚；检查异常（Checked Exception）默认不回滚。
- 性能权衡：JTA 带来两阶段提交（2PC）开销，适用于强一致性场景；若可接受最终一致性，建议改用「发件箱模式（Outbox Pattern）」+ 事件表 + 定时投递，避免分布式事务。
✅ 验证方式
启动应用后，手动在 receive() 方法末尾抛出 new RuntimeException("force rollback")，观察：
- 数据库 order_table 中无新增记录；
- IBM MQ 中原始请求消息被重新入队（可通过 MQ Explorer 查看 CURDEPTH）；
- 响应队列 ibm.mq.response 中无消息产生。
通过 JTA 统一事务管理，即可真正实现“消息即事务”的语义——让企业级集成场景下的数据一致性从理想变为现实。
