Spring Reactor中如何将Flux<Map<K, V>>转换为List<V>

安全阿岳

2026-8-31

Flux<Map<K, V>> 转 List 实现方案

核心逻辑分两步：先将每个Map中的value集合打平为单个V元素的响应式流，再将所有元素聚合为List集合。

标准实现代码

// 源响应式流示例
Flux<Map<K, V>> source = Flux.just(
        Map.of("k1", "v1", "k2", "v2"),
        Map.of("k3", "v3")
);

// 得到包装了目标List的Mono，是响应式场景下的标准返回
Mono<List<V>> listMono = source
        // 打平每个Map的value集合：将每个Map的values转为Flux，合并到主流中
        .flatMap(map -> Flux.fromIterable(map.values()))
        // 聚合所有元素为List
        .collectList();

关键注意事项

如果你需要严格保留元素的原始顺序（和上游Flux中Map的顺序、每个Map内部values的顺序一致），把flatMap替换为concatMap即可。flatMap是并行处理内部流，不保证输出顺序；concatMap会按上游顺序逐个处理，顺序完全可控。
不要在流外部手动创建ArrayList，通过doOnNext等操作符往里面add元素，这种写法存在线程安全风险，遇到流重试、异常重放的场景会产生脏数据，完全不符合响应式编程规范。
聚合后得到的是Mono<List<V>>而非直接的List<V>，这是响应式编程的异步特性决定的：集合的聚合是异步完成的，你需要通过subscribe方法订阅拿到结果；如果是在非响应式的同步代码块中调用，才可以用block()方法阻塞拿到同步的List对象，响应式链路内部严禁调用block方法，会阻塞事件循环。
如果需要对结果去重，在collectList()之前加上.distinct()操作符即可。