spring - 如何使用 Reactor (Spring WebClient) 做重复调用？

Question

我正在使用 Reactor (Spring5 WebClient) 作为我的响应式(Reactive)编程 API。我有 2 个 REST 端点可以调用。第一个的结果将是第二个的参数。对于第二个 API，它将返回一个带有“hasMore”值的结果。如果此值为 true，我应该更改分页参数并再次调用第二个 API。演示代码如下:

 client.getApi1()
        .map(r -> r.getResult())
        .flatMap(p -> client.getApi2(p, 2(page size), 1(page start)))
        .subscribe(r -> System.out.println(r.isHasmore()));

如何重复调用第二个 API (getApi2) 直到“hasMore”为假。

此外，我需要更改参数页面大小和页面开始

Answer 1

试试这段代码:

 AtomicInteger pageCounter = new AtomicInteger(0);
 client.getApi1()
    .map(r -> r.getResult())
    .flatMap(p -> client.getApi2(p, 2(page size), pageCounter.incrementAndGet()))
    .repeat()            
    .takeWhile(r -> r.isHasmore())
    .subscribe(r -> System.out.println(r.isHasmore()));

repeat() 无限调用 getApi2。takeWhile(continuePredicate) 在 continuePredicate (r.isHasmore()) 返回 true

时传递值