Project Reactor中如何将Flux转换为按sharedId分组的Map<String,List<Data>>

你使用的collectMap算子仅支持构造键-单个值的映射结构，当出现重复sharedId时会触发键冲突，同时你没有调用.block()获取Mono的最终结果，因此代码无法正常运行。

方案1：使用Reactor原生collectMultimap实现分组 #

如果需要保留反应式操作链路，可以用专门做分组归集的collectMultimap算子：

import reactor.core.publisher.Flux;
import java.util.ArrayList;
import java.util.Map;
import java.util.List;

// 代码实现
Map<String, List<Data>> dataMap = Flux.fromIterable(list)
        // 按sharedId分组，默认返回Collection<Data>
        .collectMultimap(Data::getSharedId)
        // 阻塞获取Map结果，非阻塞场景下可以直接订阅Mono<Map>
        .block()
        .entrySet()
        .stream()
        // 把Collection转为List适配你需要的返回类型
        .collect(java.util.stream.Collectors.toMap(
                Map.Entry::getKey,
                entry -> new ArrayList<>(entry.getValue())
        ));

方案2：直接使用JDK Stream实现（无反应式依赖更简洁） #

如果你的场景不需要反应式编程，直接用JDK自带的流分组即可，代码更简单：

import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

Map<String, List<Data>> dataMap = list.stream()
        .collect(Collectors.groupingBy(Data::getSharedId));

注意事项 #

• 请确保Data类提供了公有的getSharedId()方法，否则分组时无法读取私有字段值
• 反应式Web场景下如果不需要立刻拿到Map结果，不要调用.block()，直接操作返回的Mono对象即可，避免阻塞事件循环

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