Spring boot-WebFlux在运行i parallel时用id保留结果上下文

Question

使用Spring boot Web客户机从REST API请求JSON，服务器的响应体存储在一个简单的映射中。对服务器的请求包含一个ID，但它不包括在响应中，而是解释响应所需的。

        List<Map> data = Flux.fromIterable(ids)
                .parallel()
                .runOn(Schedulers.elastic())
                .flatMap(this::callAPI).sequential().collectList().block();

    private Mono<Map> callAPI(UUID id) {
        return client.get().uri(uriBuilder -> uriBuilder
                .path("/{id}/")
                .build(id))
                .retrieve().bodyToMono(Map.class);
    }

Answer 1

来自@thomasandolf评论

不从callapi函数返回mono。返回包装器对象中的映射和id，您以后可以使用这些对象重新映射到所需的结构.bodytomono（map.class).flatmap（map->{Return mono.just（new Response（id,map））；}）；-Thomas Andolf 22小时前