SpringBoot中Runnable类流式查询的事务配置问题及失效原因

场景描述 #

我有一个SpringBoot应用，接收Post请求时会启动多个线程。其中一个线程需要从数据库流式读取数据，因此让包含流式查询方法的类实现Runnable接口以独立运行，示例代码如下：

Controller代码 #

@Autowired
private DemoJPA demoJPA;

@PostMapping("/demoPost")
public ResponseEntity<?> doPost() {
    try {
        Thread t1 = new Thread(new DemoClass(demoJPA));
        t1.start();
        Thread t2 = new Thread(new AnotherClass());
        t2.start();
        return ResponseEntity.status(HttpStatus.OK).build();
    } catch (Exception e) {
        throw e;
    }
}

DemoClass代码 #

@Service
@Slf4j
@AllArgsConstructor
public class DemoClass implements Runnable {

    private final ForkJoinPool myPool = new ForkJoinPool(1000);
    private DemoJPA demoJPA;

    @Async
    public void processEntries() {
        try(Stream<DemoModel> st = demoJPA.findEntries()) {
                CompletableFuture.allOf(st.map(entry -> CompletableFuture.supplyAsync(() ->
                        doLogicMethod(entry),myPool))
                        .toArray(CompletableFuture[]::new)).join();
        }
    }

    // 业务逻辑方法

    @Override
    public void run() {
        processEntries();
    }
}

DemoJPA代码 #

@Repository
public interface DemoJPA extends JpaRepository<DemoModel,String> {
    @Query(value= "query here")
    @QueryHints(value = {
            @QueryHint(name = HINT_FETCH_SIZE, value = "" + 5),
            @QueryHint(name = HINT_CACHEABLE, value = "false"),
            @QueryHint(name = HINT_READONLY, value = "true"),
            @QueryHint(name = HINT_PASS_DISTINCT_THROUGH, value = "false")
    })
    Stream<DemoModel> findEntries();
}

遇到的问题 #

流式查询需要@Transactional(readOnly = true)维持数据库连接，但不知道该注解应放置在何处。将它加在processEntries()方法上时并未生效，报错信息为：

org.springframework.dao.InvalidDataAccessApiUsageException: You're trying to execute a streaming query method without a surrounding transaction that keeps the connection open so that the Stream can actually be consumed. Make sure the code consuming the stream uses @Transactional or any other way of declaring a (read-only) transaction.

我想知道：

1. 该注解应放在哪里才能让流式查询正常工作？
2. 为何加在processEntries()上无效？

后续可行方案 #

后来发现无需让类实现Runnable/Callable接口，直接通过Lambda创建线程调用服务方法即可正常运行，更新后的代码如下：

更新后的Controller #

@Autowired
private AnotherClass anotherClass;
@Autowired
private DemoClass demoClass;

@PostMapping("/demoPost")
public ResponseEntity<?> doPost() {
    try {
        Thread t1 = new Thread(() -> demoClass.processEntries());
        t1.start();
        Thread t2 = new Thread(() -> anotherClass.doThings());
        t2.start();
        return ResponseEntity.status(HttpStatus.OK).build();
    } catch (Exception e) {
        throw e;
    }
}

更新后的DemoClass #

@Service
@Slf4j
@AllArgsConstructor
public class DemoClass {

    private final ForkJoinPool myPool = new ForkJoinPool(1000);
    @Autowired
    private DemoJPA demoJPA;

    @Async
    public void processEntries() {
        try(Stream<DemoModel> st = demoJPA.findEntries()) {
                CompletableFuture.allOf(st.map(entry -> CompletableFuture.supplyAsync(() ->
                        doLogicMethod(entry),myPool))
                        .toArray(CompletableFuture[]::new)).join();
        }
    }

    // 业务逻辑方法
}

这种写法可正常工作，但我仍想知道最初实现Runnable的方式为何失效，毕竟Thread(() -> demoClass.processEntries())本质是创建匿名Runnable实例的语法糖，为何单独实现Runnable类的方式会出现差异？

问题解答 #

关于@Transactional的正确位置及无效原因 #

• 有效位置：
  1. 如果使用Spring管理的DemoClass实例调用方法，直接在processEntries()上添加@Transactional(readOnly = true)即可。
  2. 如果坚持用Runnable实现，需要确保DemoClass是Spring Bean，并且在run()方法上添加@Transactional(readOnly = true)（因为run()是线程执行的入口方法，Spring需要从这里介入事务）。
• 最初加在processEntries()无效的原因：
  你通过new DemoClass(demoJPA)创建的是普通Java对象，不是Spring生成的代理对象。Spring的注解（包括@Transactional）依赖AOP代理实现，直接调用普通对象的方法时，Spring无法拦截并注入事务上下文，注解完全不生效。

两种Runnable实现的核心差异 #

• 最初的写法：new DemoClass(demoJPA)创建的实例脱离了Spring容器管理，所有@Service、@Transactional、@Async注解都失去作用。调用run()后再调用processEntries()是纯普通方法调用，没有任何Spring增强逻辑，自然没有事务支持。
• Lambda写法：你调用的是Spring注入的demoClass代理对象，即使在新线程中通过Lambda调用processEntries()，依然是代理方法调用。Spring会拦截这个调用，自动注入事务上下文，保证流式查询的数据库连接保持打开状态。

本质上，两种写法的区别不是Runnable的实现形式，而是是否使用了Spring容器管理的代理对象来执行方法。Lambda只是语法糖，但背后调用的是Spring管理的Bean，而自己new出来的Runnable实例是不受Spring控制的普通对象。

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