пружинная повторная попытка с экспоненциальным откатом условно

Question

Используя пружинный реактивный WebClient, я использую API, и в случае ответа со статусом 500 мне нужно повторить попытку с экспоненциальным откатом. Но в классе Mono я не вижу retryBackoff с предикатом в качестве входного параметра.

Это функция, которую я ищу:

public final Mono<T> retryBackoff(Predicate<? super Throwable> retryMatcher, long numRetries, Duration firstBackoff)

Сейчас моя реализация выглядит следующим образом (у меня нет повторных попыток с механизмом backOff):

client.sendRequest()
    .retry(e -> ((RestClientException) e).getStatus() == 500)
    .subscribe();

Answer 1

Возможно, вы захотите взглянуть на модуль reactor-extra в проекте реактор-аддоны .В Maven вы можете сделать:

<dependency>
    <groupId>io.projectreactor.addons</groupId>
    <artifactId>reactor-extra</artifactId>
    <version>3.2.3.RELEASE</version>
</dependency>

И затем использовать это так:

client.post()
    .syncBody("test")
    .retrieve()
    .bodyToMono(String.class)
    .retryWhen(Retry.onlyIf(ctx -> ctx.exception() instanceof RestClientException)
                    .exponentialBackoff(firstBackoff, maxBackoff)
                    .retryMax(maxRetries))

Answer 2

Я не уверен, какую весеннюю версию вы используете, в 2.1.4 у меня так:

client.post()
    .syncBody("test")
    .retrieve()
    .bodyToMono(String.class)
    .retryBackoff(numretries, firstBackoff, maxBackoff, jitterFactor);

... так это именно то, что вы хотите, верно?