如何将Map类型的Flux转换为Map类型的Mono？

一、合并Flux<Map<String, List<String>>>为Mono<Map<String, List<String>>> #

场景1：每个子Map是单键值对（如示例中的singletonMap） #

直接通过collect结合Collectors.toMap，指定键提取、值提取以及相同键的List合并逻辑：

Mono<Map<String, List<String>>> monoOne = fluxOne.collect(Collectors.toMap(
    map -> map.keySet().iterator().next(),
    map -> map.values().iterator().next(),
    (existingList, newList) -> {
        List<String> merged = new ArrayList<>(existingList);
        merged.addAll(newList);
        return merged;
    }
));

场景2：子Map可能包含多个键值对 #

先将每个Map展开为键值对流，再进行收集合并：

Mono<Map<String, List<String>>> monoOne = fluxOne
    .flatMapIterable(Map::entrySet)
    .collect(Collectors.toMap(
        Map.Entry::getKey,
        Map.Entry::getValue,
        (list1, list2) -> {
            List<String> merged = new ArrayList<>(list1);
            merged.addAll(list2);
            return merged;
        }
    ));

二、合并Flux<Map<String, String>>为Mono<Map<String, String>> #

场景1：每个子Map是单键值对 #

根据需求选择相同键的处理逻辑，示例中采用新值覆盖旧值的策略：

Mono<Map<String, String>> monoTwo = fluxTwo.collect(Collectors.toMap(
    map -> map.keySet().iterator().next(),
    map -> map.values().iterator().next(),
    (oldVal, newVal) -> newVal
));

场景2：子Map可能包含多个键值对 #

同样先展开为键值对流再收集，可自定义合并逻辑：

Mono<Map<String, String>> monoTwo = fluxTwo
    .flatMapIterable(Map::entrySet)
    .collect(Collectors.toMap(
        Map.Entry::getKey,
        Map.Entry::getValue,
        (oldVal, newVal) -> newVal // 可替换为其他合并逻辑，比如拼接字符串等
    ));

示例验证结果 #

针对你提供的测试数据：

• monoOne最终得到的Map：{"one": ["one", "two"], "two": ["one", "two"]}
• monoTwo最终得到的Map：{"one": "two"}（两个重复键的子Map，最终保留最后一个值）

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