Пользовательская повторная попытка в Reactor - PullRequest
Новая
       24

Пользовательская повторная попытка в Reactor

0 голосов
/ 10 ноября 2018

Я пытался реализовать логику повторов в Kotlin и Reactor на основе возможностей дополнительного пакета Reactor. Я пытаюсь передать список длительностей, и на каждом context.iteration я получаю (iteration-1) -й элемент списка. Это работает частично , я всегда получаю IndexOutOfBoundsException на последней итерации, что больше, чем я хотел, хотя я предоставил максимальное количество повторов - размер списка. Повторные попытки выполняются, хотя, через определенную продолжительность и «правильное» количество раз (конечно, потому что IndexOutOfBoundsException предотвращает больше), только это исключение (и его основная причина) беспокоит меня.

Это мой пользовательский интерфейс BackOff: 

interface MyCustomBackoff : Backoff {
    companion object {
        fun getBackoffDelay(backoffList: List<Duration>): (IterationContext<*>) -> BackoffDelay {
            return { context -> BackoffDelay(backoffList[(context.iteration() - 1).toInt()]) }
        }
    }
}

И мое расширение Kotlin: 

fun <T> Mono<T>.retryCustomBackoffs(backoffList: List<Duration>, doOnRetry: ((RetryContext<T>) -> Unit)? = null): Mono<T> {
    val retry = Retry.any<T>().retryMax(backoffList.size.toLong()).backoff(MyCustomBackoff.getBackoffDelay(backoffList))

    return if (doOnRetry == null) {
        this.retryWhen(retry)
    }
    else {
        this.retryWhen(retry.doOnRetry(doOnRetry))
    }
}

Что мне здесь не хватает?

1 Ответ

0 голосов
/ 12 ноября 2018

Если вы посмотрите на reactor.retry.AbstractRetry#calculateBackoff, вы можете обнаружить, что есть специальный BackoffDelay с именем RETRY_EXHAUSTED. И он возвращается, когда retryContext.iteration() > maxIterations (не >=) после backoff.apply(retryContext)

if (retryContext.iteration() > maxIterations || Instant.now(clock).plus(jitteredBackoff).isAfter(timeoutInstant))
    return RETRY_EXHAUSTED;

Итак, если у вас есть 2 пользовательские задержки отката в списке, будет 3 задержки отсрочки, сгенерированные calculateBackoff.

Вы можете изменить свой MyCustomBackoff следующим образом (извините за Java, я не знаком с Kotlin): 

public interface MyCustomBackoff extends Backoff {
    static Backoff getBackoffDelay(List<Duration> backoffList) {
        return context -> context.iteration() <= backoffList.size() ?
                new BackoffDelay(backoffList.get(Long.valueOf(context.iteration() - 1).intValue())) :
                new BackoffDelay(Duration.ZERO);
    }
}
...