如何延迟重复的WebClient获取请求

Question

我正在使用Spring5WebClient从RESTAPI重复获取运行进程的某些状态。

在这里的帮助下，我现在找到了这个解决方案：

webClient.get().uri(...).retrieve.bodyToMono(State.class)
          .repeat()
          .skipUntil(state -> stateFinished())
          .limitRequest(1)
          .subscribe(state -> {...});

在这种情况下，get请求以非常高的速率触发。什么是正确的方法来限制请求速率，让我们说每秒1个请求？

我尝试使用delayElements（Duration.ofSeconds（1）），但这只会延迟结果，而不会延迟请求本身。

Answer 1

您正在使用的delayElements告诉我您将它放在重复之后。您要延迟的是对WebClient的订阅。

webClient
      .get()
      .uri(...)
      .retrieve
      .bodyToMono(State.class)
      .delaySubscription(Duration.ofSeconds(1)) //Just add this before the repeat
      .repeat()
      .skipUntil(state -> stateFinished())
      .limitRequest(1)
      .subscribe(state -> {...});

这样做可以确保在第n个请求的响应和第n个请求的触发之间有第二次。如果您需要固定的呼叫频率，而不管每个请求响应的时间，请按照Roman的建议，用Flux.interval包装您的代码。

Answer 2

在你的情况下，还有一个小的变通方法，你用一个通量作为限制器来压缩你的每个呼叫。

.zipWith(Flux.interval(Duration.of(1, ChronoUnit.SECONDS)))

虽然我认为delayElements（）是有效的，但也许你没有把它放在WebClient堆栈的正确阶段。

Answer 3

您可以在自定义实现的配套的Publisher中使用重复时运算符

Mono.just("test")
        .repeatWhen(longFlux -> Flux.interval(Duration.ofSeconds(1)))
        .take(5)
        .log()
        .blockLast();

或者使用Reactor插件的Repeate功能

Mono.just("test")
        .repeatWhen(Repeat.times(Long.MAX_VALUE)
                .fixedBackoff(Duration.ofSeconds(1)))
        .take(5)
        .log()
        .blockLast();