如何从第一次调用的列表中链接每个项目的webclient调用

Question

我有两个目标

CarParts {
    String   id
    WorkItem workItem
}

WorkItemResponse {
    List<WorkItem> resource; <- always contains one item.
}

我想在汽车零件上创建一个webclient，它将返回给我一个Mono

我也想做一个

Mono<List<Carparts>> carpartsmono = webclient.get.exchange();

Mono<WorkItemResponse> itemResponse = webclient.get().uri( item.id of carparts)

carpartsMono.flatmap(item -> item.stream().map(t -> t.setWorkItem(webclient.get("uri + 
     t.getId)).block().getResource().get(0)).collect(Collectors.AsList));

但是我找不到解决办法。




Answer 1

在反应式堆栈中，应尝试使所有代码异步，在您的情况下，其中一种方式如下所示：

Flux<CarPart> carPartFlux=
    webClient.get()
    .uri("/car-parts/{id}")
    .exchange()
    .bodyToFlux(CarParts.class)
    .map(carPart ->  {
        return
        webclient.get()
                 .uri("/workitems/" + cartPart.getWorkItemId())
                 .exchange()
                 .bodyToMono(WorkItemResponse.class)
                 .map(workitem ->  {
                      carPart.setWorkItem(workitem);
                      return carPart;
                 });
                 
    });

现在你可以通过汽车零件的测试了。请尽量避免。尽可能长的阻止调用。若要将其发送到RESTAPI客户端，则直接在RESTAPI响应中传递carPartMono。

上面的代码也是示例，可以根据当前的执行条件进一步改进。比如缓存可以帮助。因此，您可以从这个开始，监控性能并采取下一步措施。