Spring Boot循环内使用REQUIRES_NEW事务的异常处理问题

我来帮你拆解下当前遇到的事务问题核心，以及对应的解决办法：

核心问题原因 #

你现在的问题根源有两个：

1. Service2内部捕获异常导致事务不回滚：Spring的事务管理器是通过未被上层捕获的异常来触发事务回滚逻辑的。你在Service2.m2()方法里把异常直接catch住了，Spring根本没察觉到异常发生，自然不会回滚这个REQUIRES_NEW的独立事务。
2. 直接抛出异常会终止外层流程：如果在Service2的catch块里重新抛出异常，外层Service1的事务会感知到异常，虽然当前Service2的事务会回滚，但外层事务会被标记为需要回滚，而且未被捕获的异常会终止整个循环，导致剩余元素无法处理。

正确的解决方案 #

我们需要做到：每个元素的独立事务异常时自动回滚，同时外层循环不受影响，继续处理剩余元素。具体调整如下：

1. 修改Service2：移除内部异常捕获，让异常自然抛出 #

把Service2.m2()里的try-catch去掉，让RuntimeException直接抛出去，这样Spring的事务管理器能感知到异常，触发REQUIRES_NEW事务的回滚：

@Service
public class Service2 {
    @Autowired
    private LogService logger;

    @Transactional(transactionManager = "transactionManager", propagation = Propagation.REQUIRES_NEW)
    public void m2(int i) {
        Log log = new Log();
        log.setDataMensagem(new Date());
        log.setDescricaoEnvioRecebimento("TEST");
        log.setDescricaoMensagem("TEST1");
        log.setIdMensagem("TEST2");
        log.setNomeFilaServico("TESTE3");
        logger.save(log);
        
        if (i == 2) {
            throw new RuntimeException("处理元素i=" + i + "时触发异常");
        }
    }
}

2. 修改Service1：在循环内部捕获异常，保证流程继续 #

在Service1.m1()的循环里增加try-catch，捕获Service2抛出的异常，这样既不会让外层事务感知到异常（避免外层回滚），又能继续处理下一个元素：

public class Service1 {
    @Autowired
    private Service2 service2;

    @Transactional(transactionManager = "transactionManager", propagation = Propagation.REQUIRED)
    public void m1() {
        List<Integer> list = Arrays.asList(1, 2);
        for (Integer j : list) {
            try {
                service2.m2(j);
                System.out.println("成功处理元素j = " + j);
            } catch (RuntimeException e) {
                System.out.println("处理元素j = " + j + "时发生异常，已回滚当前事务：" + e.getMessage());
                // 捕获异常后，循环会继续执行，处理下一个元素
            }
        }
    }
}

为什么这样能解决问题？ #

• 独立事务回滚：Service2.m2()的REQUIRES_NEW注解会为每个元素创建独立事务，当抛出未被捕获的RuntimeException时，Spring会自动回滚这个独立事务，之前的logger.save()操作也会被撤销。
• 外层流程不受影响：异常被Service1循环内的catch块捕获，外层的REQUIRED事务不会感知到这个异常，因此不会被标记回滚，循环可以继续处理剩余元素。
• 符合Spring事务规则：Spring默认只对未被捕获的RuntimeException和Error触发回滚，这里用RuntimeException完全符合规则，不需要额外配置。

额外注意事项 #

• 如果需要处理Checked Exception，可以在事务方法上添加@Transactional(rollbackFor = Exception.class)来指定回滚的异常类型。
• 不要在事务方法内部手动catch异常后不做任何回滚操作，要么抛出异常让Spring处理，要么手动调用TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()标记事务需要回滚（不过抛异常的方式更简洁）。

内容的提问来源于stack exchange，提问作者Lucas Amorim Silva