Spring Reactor中Flux<Item>转List<Item>遇block报错的解决方法

错误分析 #

• 违反Reactive线程模型：block()会强制阻塞当前线程等待结果，但你当前处于Reactor的reactor-http-nio-*线程（WebFlux专属IO线程），这类线程设计用于非阻塞IO处理，禁止执行阻塞操作——一旦阻塞会导致线程池耗尽、服务响应性能暴跌甚至不可用。
• 类型赋值错误：itemFlux.collectList()返回Mono<List<Item>>，调用block()后直接得到List<Item>，但你将其赋值给Mono<List<Item>>类型变量，属于编译错误。

解决方案 #

根据调用方环境不同，分两种场景处理：

1. 调用方为非Reactive环境（如传统Spring MVC、普通同步代码）

必须做阻塞转换时，要将阻塞操作转移到专门的线程池执行：

// 修正类型+将阻塞操作放到boundedElastic线程池
List<Item> itemList = Flux.fromIterable(searchRequestByItemType.entrySet())
        .flatMap(e -> getService(e.getKey()).searchItems(e.getValue()))
        .collectList()
        .subscribeOn(Schedulers.boundedElastic()) // 用Reactor专为阻塞操作设计的线程池
        .block();

Schedulers.boundedElastic()会动态创建线程处理阻塞任务，既避免阻塞IO线程，又通过线程数量限制防止资源耗尽。

2. 调用方为Reactive环境（如Spring WebFlux控制器）

绝对禁止使用block()，直接返回Mono<List<Item>>保持Reactive链条完整性：

Mono<List<Item>> itemListMono = Flux.fromIterable(searchRequestByItemType.entrySet())
        .flatMap(e -> getService(e.getKey()).searchItems(e.getValue()))
        .collectList();
// 直接返回给Reactive调用方，无需任何阻塞操作

Reactive编程的核心是异步非阻塞，所有操作应通过Mono/Flux链式调用完成，才能发挥其性能优势。

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