Spring Boot+Atomikos：事务JMS监听器try-catch内抛异常直接触发回滚

咱们先把问题核心理清楚：你在消息处理的主事务里抛出异常后，当前JTA事务会被立即标记为回滚状态，如果catch块里的日志记录方法和主事务共用同一个事务上下文，那日志操作也会跟着回滚，而且你会误以为事务直接回滚没执行后续操作。另外，Spring的事务拦截器默认会在方法抛出未捕获的RuntimeException时触发回滚，哪怕你catch了异常，处理不当的话主事务的回滚时机也不符合预期。

下面是具体的解决步骤：

1. 让日志记录方法使用独立事务 #

要让异常时的日志记录不受主事务回滚影响，必须给日志方法配置新的独立事务。在Spring中通过@Transactional的传播属性实现：

@Service
public class LogService {

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void recordErrorLog(String message) {
        // 这里执行日志插入/更新操作，这个事务会独立提交，和主事务完全隔离
    }
}

REQUIRES_NEW会强制启动一个新的JTA事务，执行完日志操作后立即提交，不会被主事务的回滚状态影响。

2. 正确处理主事务的异常与回滚标记 #

在消息处理器的事务方法中，捕获异常后先调用日志方法，然后手动标记主事务为回滚状态（或者重新抛出异常），这样主事务会在所有操作完成后再执行回滚：

@Service
public class MessageHandlerService {

    @Autowired
    private LogService logService;

    @Transactional  // 该方法运行在JTA主事务中
    public void handleMessage(Message message) {
        try {
            // 消息处理逻辑，这里抛出异常
            throw new RuntimeException("消息处理失败");
        } catch (Exception e) {
            // 先调用独立事务的日志方法
            logService.recordErrorLog("消息处理失败：" + e.getMessage());
            
            // 手动标记主事务为回滚状态，确保最终回滚（不会立即触发）
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            
            // 如果需要让JMS容器感知异常（比如触发死信队列），可以选择重新抛出异常
            // throw new RuntimeException("处理失败，已记录日志", e);
        }
    }
}

这里的关键是setRollbackOnly()：它只是标记当前事务需要回滚，不会立即触发回滚，而是等方法执行完所有操作后，由Atomikos的JTATransactionManager统一处理回滚，这样就能保证catch块里的操作（包括独立事务的日志）都执行完毕后再回滚主事务。

3. 检查DefaultMessageListenerContainer的事务配置 #

确保消息监听容器正确绑定Atomikos的JTATransactionManager，并且事务属性配置符合预期：

@Bean
public DefaultMessageListenerContainer jmsListenerContainer(ConnectionFactory connectionFactory,
                                                           MessageListener messageListener,
                                                           JTATransactionManager transactionManager) {
    DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setMessageListener(messageListener);
    container.setDestinationName("your-queue-name");
    container.setTransactionManager(transactionManager);
    // 显式配置事务传播属性，默认就是REQUIRED，可确保事务生效
    container.setTransactionAttribute(new DefaultTransactionAttribute(TransactionDefinition.PROPAGATION_REQUIRED));
    container.setSessionTransacted(true); // 必须开启事务会话，配合JTA事务
    return container;
}

setSessionTransacted(true)是关键，它告诉JMS容器使用事务会话来配合JTA事务管理。

4. 验证Atomikos的JTA配置 #

确保Spring Boot中Atomikos的配置正确，数据源、JMS连接工厂都使用Atomikos的XA兼容实现：

# Atomikos JTA核心配置
spring.jta.atomikos.connectionfactory.max-pool-size=5
spring.jta.atomikos.datasource.max-pool-size=10
# 其他XA数据源/JMS连接工厂的具体配置...

只有使用XA兼容的资源，JTA事务才能正确管理多个资源的一致性。

常见误区提醒 #

• 不要在catch块中捕获所有异常却不标记回滚：如果你的事务方法是Spring代理的，catch了所有异常且不做回滚标记，Spring会默认提交事务，这不符合你回滚消息处理操作的预期。
• 避免日志方法使用默认的Propagation.REQUIRED：这样日志操作会加入主事务，主事务回滚时日志也会被回滚，等于白记录了。

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