如何在Spring Boot 3.x WebFlux中将Flux<Mono<String>>转换为List<String>

安全阿岳

2026-6-15

将Flux<Mono>转换为List的实现方案

核心思路

Flux<Mono<String>>是包含多个Mono<String>的响应式序列，要转换为List<String>，需要先将每个内部的Mono<String>扁平化（展开为单个String元素），再收集所有元素为同步列表。

方案1：同步获取List（适合测试/命令行等必须阻塞的场景）

通过flatMap扁平化流，再用collectList收集为Mono<List<String>>，最后调用block()阻塞获取结果：

// 假设这是你的Flux<Mono<String>>实例
Flux<Mono<String>> fluxOfMonos = ...;

List<String> resultList = fluxOfMonos
    // 扁平化每个Mono<String>，将其发射的String合并到同一Flux中
    .flatMap(Function.identity())
    // 收集所有元素为Mono<List<String>>
    .collectList()
    // 阻塞当前线程直到结果返回
    .block();

方案2：异步处理结果（推荐的响应式方式）

如果不需要同步阻塞获取，可通过subscribe异步处理收集到的列表：

fluxOfMonos
    .flatMap(Function.identity())
    .collectList()
    .subscribe(
        list -> {
            // 这里处理转换后的List<String>
            System.out.println("处理结果：" + list);
        },
        throwable -> {
            // 处理异常情况
            throwable.printStackTrace();
        }
    );

关键注意事项

避免在WebFlux请求线程中调用block()：WebFlux依赖非阻塞线程模型，阻塞会导致线程耗尽，严重影响性能。如果必须同步获取，建议指定独立线程池：

List<String> resultList = fluxOfMonos
    .flatMap(Function.identity())
    .collectList()
    // 切换到弹性线程池执行，避免阻塞主线程
    .subscribeOn(Schedulers.boundedElastic())
    .block();