如何在 spring webflux/webclient 中有条件地链接 webclient 调用

Question

我正在尝试使用 WebClient 实现以下场景。使用 RestTemplate 很简单，但我不能再这样做了。

伪java代码中Spring控制器的相关部分：

Mono<T1> t1 = webClient.get()...retrieve()...;
Mono<T2> t2;

if (t1.getResult().getValue() > 0) {
    t2 = webClient.get().buildUsing(t1.getResult().getValue())...retrieve()...);
} else {
    t2 = Mono.empty();
}

return(Mono.zip(t1, t2, mergeFunction));

我不是在问如何使用 Webflux。我还可以自己添加错误处理。我的问题是，如果第一个调用成功，如何将数据传递给第二个调用，以及在哪里合并两个调用的结果，其中一个调用可能会发生也可能不会发生。如果我可以使用 RestTemplate，这个任务绝对是微不足道的。

有一个标题非常相似的问题，但没有得到解答。

Answer 1

我认为zipWhen非常适合这个目的。zipWhen等待第一个单声道的结果，然后将两个结果组合成一个Tuple2

WebClient.builder().baseUrl("https://jsonplaceholder.typicode.com/todos/1")
    .build()
    .get()
    .retrieve()
    .bodyToMono(User.class)
    .zipWhen(r -> {
      if (r.getId() == 1) {
        return  WebClient.builder().baseUrl("https://jsonplaceholder.typicode.com/todos/2")
            .build()
            .get()
            .retrieve()
            .bodyToMono(User.class);
      } else {
        return Mono.empty();
      }
    });

结果是同时Mono<Tuple2<T, T2>>保留这两个值。