java - 带有 flatmap 和 takewhile 的 Spring reactor webclient 顺序请求

Question

我想从第三方资源中检索所有页面。为此，我写了这个:

final WebClient webClient = WebClient.builder()
     .baseUrl("http://resource.com")
     .build();
Flux.fromStream(IntStream.iterate(0, i -> i + 1).boxed())
     .flatMap(i -> webClient.get()
          .uri("/data?page={page}", i)
          .retrieve()
          .bodyToMono(Page.class))
     .takeWhile(Page::isMoreAvailable)
     .flatMapIterable(Page::getData)

但它不能正常工作。 flatMap 被多次调用，它在 takeWhile 检索第一个响应之前对不同的页面执行多个请求。

如果我把它改成这样:

.map(i -> webClient.get()
        .uri("/data?page={page}", i)
        .retrieve()
        .bodyToMono(Page.class)
        .block())

效果很好。

那么，如何使用 flatMap 实现这一点？

Answer 1

好的，所以平面图处理并发

.flatMap(i -> webClient.get()
   .uri("/data?page={page}", i)
   .retrieve()
   .bodyToMono(Page.class), 1)

成功了。