使用Stream时Spring @Transactional(REQUIRES_NEW)为何失效？

因需处理海量实体，原List遍历方式引发内存溢出，故改为Stream遍历。但出现异常时，调用带@Transactional(propagation = Propagation.REQUIRES_NEW)的myService.doSomeWork()方法插入的数据全部丢失；而原List版本中，该方法的操作会因独立事务保留在数据库中。开启Spring事务日志后，两种场景均显示每次调用doSomeWork()都会创建新事务，但Stream版本异常后数据丢失。请问这是Stream与事务交互的已知行为，还是Spring的Bug？

场景伪代码 #

正常工作的List版本 #

@Transactional
public void myMethod()
{
     List<MyEntity> myEntities = myRepo.findAllBySomething("foo");

     for(MyEntity myEntity : myEntities)
     {
          myService.doSomeWork();
     }
}

@Service
public class MyService {

     @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void doSomeWork() {
       SomeOtherEntity someOtherEntity = new SomeOtherEntity();
       // 初始化属性
       someOtherRepo.save(someOtherEntity);
     }
}

出现问题的Stream版本 #

@Transactional
public void myMethod()
{
     try (Stream<MyEntity> myStream = myRepo.findAllBySomething("foo")) {

          Iterator<MyEntity> myStreamIterator = myStream.iterator();

          while (myStreamIterator.hasNext()) {
               MyEntity myEntity = myStreamIterator.next();

               myService.doSomeWork();

          }
     }
}

解答 #

这属于Spring Data JPA Stream与事务交互的已知行为，并非Spring Bug，核心原因在于Stream的延迟加载特性与外层事务的绑定关系：

1. List版本的事务隔离逻辑
   调用myRepo.findAllBySomething返回List时，数据会一次性加载到内存，此时Spring Data JPA会立即关闭与外层事务绑定的EntityManager结果集，释放数据库连接。后续遍历List时，外层事务的连接已处于空闲状态，每次调用doSomeWork()的REQUIRES_NEW事务会独立获取连接、提交数据，即使外层事务后续异常回滚，也不会影响已提交的独立事务数据。

2. Stream版本的事务冲突点
   Spring Data JPA返回的Stream是延迟加载的结果集，它与外层事务的EntityManager强绑定，遍历过程中（next()调用时）会持续占用外层事务的数据库连接。此时调用doSomeWork()的REQUIRES_NEW事务，若连接池配置导致复用了外层事务的同一个数据库连接，虽然Spring日志显示创建了新事务，但数据库层面，同一个连接上的事务切换可能存在状态残留：

   • 当外层事务因异常触发回滚时，数据库连接的事务上下文会被重置，导致之前REQUIRES_NEW事务提交的数据被意外回滚（部分数据库驱动在连接复用场景下的特殊处理）；
   • 另外，Stream的try-with-resources自动关闭逻辑，会触发外层EntityManager的清理操作，进一步干扰了独立事务的提交状态。

解决方法 #

• 剥离Stream与外层事务的绑定：获取Stream时，使用@Transactional(propagation = Propagation.NOT_SUPPORTED)，让Stream在无事务上下文的环境中加载，避免占用外层事务连接：

  public void myMethod()
  {
       // 无事务上下文获取Stream，避免占用事务连接
       try (Stream<MyEntity> myStream = myRepo.findAllBySomething("foo")) {
            Iterator<MyEntity> myStreamIterator = myStream.iterator();
            while (myStreamIterator.hasNext()) {
                 MyEntity myEntity = myStreamIterator.next();
                 // 内部REQUIRES_NEW事务独立执行
                 myService.doSomeWork();
            }
       }
  }
  

• 强制为REQUIRES_NEW事务分配独立连接：调整数据源连接池配置，确保事务能获取独立连接（例如增加连接池大小、配置事务隔离级别为读已提交）；
• 批量提交+手动事务控制：将Stream遍历的元素分批处理，每批手动控制事务提交，避免长时间占用连接。

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