SpringBoot：如何使用反应式编程调用API链？

Question

我想在另一个Flux流中间调用Mono，向mono发送Flux参数。我正在使用SpringBoot的WebClient。

我试过这个：

WebClient client = WebClient.create();
    client.get().uri("http://localhost:8081/api/{param1}", param1)
        .retrieve()
        .bodyToFlux(String.class)
        .zipWith(
            client.get().uri("http://localhost:8082/api/{param2}", param2)
            .retrieve()
            .bodyToMono(String.class);
        )
        .map(tuple -> {
          return tuple.getT1() + tuple.getT2();
        })

但是，如何将第一个API调用的返回发送给param2？然后得到双方的回应？第一个API返回许多值，对于每个值，我需要调用第二个API。

谢谢

Answer 1

我就是这样做的：

WebClient client = WebClient.create();
client.get().uri("http://localhost:8081/api/{param1}", param1)
    .retrieve()
    .bodyToFlux(String.class)
    .flatMap(
        response1 -> 
            client.get().uri("http://localhost:8082/api/{param2}", response1)
                .retrieve()
                .bodyToMono(String.class)
                .map(response2 -> new Response(response1, response2))
     )
     , Response.class
     )