Spring Boot中forEach循环迭代独立事务回滚问题排查

你的核心问题是Spring事务代理未生效：

• 当processLabResults加@Transactional时，内部直接调用processDiagnosis属于同一类内方法调用，Spring AOP代理不会介入，REQUIRES_NEW注解完全失效，所有迭代共享同一个外层事务，一旦标记回滚，整个大事务都会回滚。
• 去掉外层@Transactional后，内部调用依然不走代理，processDiagnosis的事务注解不生效，没有事务上下文，所以调用TransactionInterceptor.currentTransactionStatus()会报错。

最规范的做法是把需要独立事务的方法抽成单独的Service类，让Spring代理生效，确保每次调用都开启新事务。

步骤1：拆分独立事务方法到新Service #

@Service
public class DiagnosisService {
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void processDiagnosis() {
        boolean isDispositionUpdated = updateDisposition(); // 调用JPA Repository执行更新
        if (isDispositionUpdated) {
            boolean isSomethingElseUpdated = updateSomethingElse(); // 调用JPA Repository执行更新
            if (!isSomethingElseUpdated) {
                // 仅标记当前REQUIRES_NEW事务回滚，不影响之前已提交的事务
                TransactionInterceptor.currentTransactionStatus().setRollbackOnly();
            }
        }
    }

    // 实现updateDisposition和updateSomethingElse方法
}

步骤2：在原Service中注入新Service并调用 #

@Service
public class MyService {
    private final DiagnosisService diagnosisService;

    // 构造注入（Spring推荐方式）
    public MyService(DiagnosisService diagnosisService) {
        this.diagnosisService = diagnosisService;
    }

    // 外层不需要加@Transactional，避免干扰独立事务
    public void processLabResults() {
        arrayList.forEach(i -> {
            diagnosisService.processDiagnosis();
        });
    }
}

替代方案（同类内调用代理） #

如果不想拆分类，可以通过Spring上下文获取自身的代理对象来调用方法，触发AOP：

@Service
public class MyService implements ApplicationContextAware {
    private MyService selfProxy;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        selfProxy = applicationContext.getBean(MyService.class);
    }

    // 外层不加@Transactional
    public void processLabResults() {
        arrayList.forEach(i -> {
            // 通过代理对象调用，触发REQUIRES_NEW事务
            selfProxy.processDiagnosis();
        });
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void processDiagnosis() {
        boolean isDispositionUpdated = updateDisposition();
        if (isDispositionUpdated) {
            boolean isSomethingElseUpdated = updateSomethingElse();
            if (!isSomethingElseUpdated) {
                TransactionInterceptor.currentTransactionStatus().setRollbackOnly();
            }
        }
    }
}

• 修复代码里的拼写错误：proccessDiagnosis应为processDiagnosis，isUpdated应为isDispositionUpdated，避免逻辑错误。
• REQUIRES_NEW会强制开启新事务，之前的事务会被挂起，当前事务完成后才恢复，确保每个迭代的事务独立，回滚仅影响当前迭代。
• 编程式回滚setRollbackOnly()只会标记当前事务需要回滚，事务会在方法执行完毕后自动回滚，无需手动触发，也不会影响其他已提交的独立事务。

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