如何在不阻塞单个调用的前提下，将WebClient并行调用的Mono响应转换为以输入ID为键的HashMap

嗨，这个问题我刚好有经验，完全可以帮你搞定！你想要并行调用WebClient获取用户，然后把结果转换成以ID为键的HashMap，还不想阻塞单个调用，其实用响应式的原生操作就能完美解决，根本不需要用doOnSuccess这种副作用方法——毕竟doOnSuccess本来就不是用来构建结果的，而且手动操作HashMap还可能有线程安全问题。

先给你看最直接的改造方案，和你原来的代码结构最接近：

public Map<Integer, User> fetchUsers(List<Integer> ids) {
    // 把每个ID对应的Mono<User>包装成包含ID和User的Entry
    List<Mono<Map.Entry<Integer, User>>> entryMonos = ids.stream()
            .map(id -> webClient.get()
                    .uri("/otheruser/{id}", id)
                    .retrieve()
                    .bodyToMono(User.class)
                    // 把User和对应的ID绑定成键值对条目
                    .map(user -> new AbstractMap.SimpleEntry<>(id, user)))
            .collect(Collectors.toList());

    // 合并所有异步调用结果，然后收集成Map
    return Flux.merge(entryMonos)
            .collectMap(Map.Entry::getKey, Map.Entry::getValue)
            .block(); // 和你原代码一样最后阻塞获取结果
}

这个做法的核心是：每个异步调用的结果都带上对应的ID，然后用Reactor提供的collectMap操作安全地把所有条目收集成Map。全程所有WebClient调用都是并行执行的，没有阻塞任何单个请求，而且collectMap是线程安全的，不会出现手动操作HashMap的并发问题。

如果你想让代码更简洁，还可以直接用Flux的并行流来处理，不用先创建List：

public Map<Integer, User> fetchUsers(List<Integer> ids) {
    return Flux.fromIterable(ids)
            .parallel() // 显式开启并行处理
            .flatMap(id -> webClient.get()
                    .uri("/otheruser/{id}", id)
                    .retrieve()
                    .bodyToMono(User.class)
                    .map(user -> new AbstractMap.SimpleEntry<>(id, user)))
            .sequential() // 转回串行以安全收集Map
            .collectMap(Map.Entry::getKey, Map.Entry::getValue)
            .block();
}

另外，如果你想让方法完全非阻塞（更符合Reactive编程的最佳实践），可以去掉最后的block()，返回Mono<Map<Integer, User>>，让调用方自己决定是否阻塞或者继续链式调用：

public Mono<Map<Integer, User>> fetchUsersReactive(List<Integer> ids) {
    return Flux.fromIterable(ids)
            .flatMap(id -> webClient.get()
                    .uri("/otheruser/{id}", id)
                    .retrieve()
                    .bodyToMono(User.class)
                    .map(user -> new AbstractMap.SimpleEntry<>(id, user)))
            .collectMap(Map.Entry::getKey, Map.Entry::getValue);
}

最后再提醒一下：千万别用doOnSuccess往HashMap里塞数据，因为doOnSuccess是副作用操作，多个并行请求同时修改同一个HashMap会有线程安全风险，而且这种方式也不符合响应式编程的设计思想。用上面的方法既高效又安全，完全满足你的需求~

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