Spring Boot响应式编程中subscribeOn(boundedElastic)线程异常问题

问题根源：你看到的日志不在响应式流的执行阶段 #

• Controller里的logger.info("all-book-details: ...")是返回Flux之前的同步代码，此时WebFlux的请求处理线程（http-nio-xxx）还在处理请求，响应式流还没触发订阅，subscribeOn完全没生效。
• Service里的logger.info("book-details1: ...")同样是在构建Flux的同步阶段执行的，流还没开始订阅，自然还是用的http-nio线程。

搞懂subscribeOn的作用时机 #

subscribeOn的作用是指定订阅发生时，整个响应式流上游操作的执行线程——它影响的是流启动后的异步操作（比如repository.findAll()、delayElements这些流中的步骤），而不是构建Flux时的同步代码。

验证boundedElastic是否生效的正确方式 #

把日志放到流的异步操作里，比如doOnNext或者map中，就能看到线程切换：

@Override
public Flux<Book> getAll() {
    return bookRepository
            .findAll()
            .doOnNext(book -> logger.info("findAll执行线程: " + Thread.currentThread().getName()))
            .delayElements(Duration.ofSeconds(2))
            .doOnNext(book -> logger.info("delayElements执行线程: " + Thread.currentThread().getName()))
            .map(book -> {
                logger.info("map执行线程: " + Thread.currentThread().getName());
                book.setName(book.getName().toUpperCase());
                return book;           
            });
}

此时你会看到这些日志的线程是boundedElastic-xxx，说明subscribeOn已经生效。

让service流操作全跑在boundedElastic上的正确姿势 #

如果希望service里的所有流操作都切换到boundedElastic线程，建议把subscribeOn放在service流的最前端，确保覆盖所有上游操作：

@Override
public Flux<Book> getAll() {
    return bookRepository
            .findAll()
            .subscribeOn(Schedulers.boundedElastic()) // 放在这里，确保repository查询也用boundedElastic
            .delayElements(Duration.ofSeconds(2))
            .map(book -> {
                book.setName(book.getName().toUpperCase());
                return book;           
            });
}

当然也可以保留Controller里的subscribeOn，只要清楚它会影响整个流的订阅线程，包括service里的所有流操作。

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