使用Spring WebFlux中的webclient在Mono上有条件地重复或重试

Question

我要做的是用WebClient对Webflux中的单声道进行有条件的重复。情况如下：

我们有一些返回生成文档的业务rest服务。此文档的生成是从在此文档之前调用的另一个服务触发的。但是，回到业务：文档生成服务需要10-30秒。我们要做的是：10秒后检查是否生成了文档（单）。如果是这样，一切都很好。如果没有，请在5秒后重复（或重试）并检查是否生成了文档。以此类推，直到（最坏的情况）30秒后超时。这可能吗？一些（伪）代码：

return this.webClient.post().uri(SERVICE_URL)).        
body(BodyInserters.fromObject(docRequest)).retrieve().
bodyToMono(Document.class).
delaySubscription(Duration.ofSeconds(10)).
repeat5TimesWithDynamicTimeDelayUntil(!document.isEmpty()).
subscribe();

格雷茨·贝尔纳多

Answer 1

是的，有可能。

mono有两个重新订阅（从而重新触发请求）的概念

• 重试=如果上游完成并出现异常，则重新订阅
• repeat=如果上游成功完成，则重新订阅

java prettyprint-override">// From reactor-core >= v3.3.4.RELEASE
import reactor.util.retry.Retry;

this.webClient
        .post()
        .uri(SERVICE_URL)
        .body(BodyInserters.fromValue(docRequest))
        .retrieve()
        .bodyToMono(Document.class)
        .retryWhen(Retry.fixedDelay(5, Duration.ofSeconds(5)))
        .delaySubscription(Duration.ofSeconds(10))

注意上面使用的retryWhen(Retry)方法是在Reactor核心V3.3.4.release中添加的，而retryWhen(Function)方法是不推荐的。在reactor-core V3.3.4.发布之前，您可以使用reactor-extras项目中的重试函数生成器创建函数来传递给RetryWhen(function)。

如果成功后需要重复，请使用.repeatWhen或.repeatWhenEmpty而不是上面的.retryWhen。

使用repeat function builder from reactor-extras项目创建repeat函数，如下所示：

// From reactor-extras
import reactor.retry.Repeat;

this.webClient
        .post()
        .uri(SERVICE_URL)
        .body(BodyInserters.fromValue(docRequest))
        .retrieve()
        .bodyToMono(Document.class)
        .filter(document -> !document.isEmpty())
        .repeatWhenEmpty(Repeat.onlyIf(repeatContext -> true)
                .exponentialBackoff(Duration.ofSeconds(5), Duration.ofSeconds(10))
                .timeout(Duration.ofSeconds(30)))
        .delaySubscription(Duration.ofSeconds(10))

如果要在成功或失败时重新订阅，还可以将.retry*与.repeat*链接起来。