如何使用 Spring WebClient 从并行 Web 请求中收集结果？

Question

我想发送并行 Web 请求并同时收集结果。 然后我的方法应该返回聚合结果。

使用spring-webflux 和WebClient 听起来很简单。但是我如何才能真正汇总结果呢？

public List<Response> aggregate(List<Object> bodys) {
    List<Mono> monos = bodys.stream(body -> send(body)).collect(Collectors.toList());

    //TODO how can I get all results in parallel and collect it to a response list?
    List<Response> = Flux.merge(monos)...???...collectList(); //pseudeocode
}

private Mono<Response> send(Object body) {
   return webClient.post().syncBode(body).bodyToMono(type);
}

重要的是：如果其中一个单声道以异常结束，其他单声道仍应执行而不是中止。

Answer 1

您需要在内部 Monos 上应用错误处理：

public Mono<List<Response>> aggregate(List<Object> bodies)
{
    return Flux.fromIterable(bodies)
               .flatMap(body -> send(body).onErrorResume(e -> Mono.empty()))
               .collectList();
}

private Mono<Response> send(Object body)
{
    return WEB_CLIENT.post().syncBody(body).retrieve().bodyToMono(Response.class);
}