quarkus - 使用 .onFailure().retry() 时如何记录每个 throwable 并在重试之间有延迟

Question

使用 Vert.x WebClient 时，我需要在每个失败的 http 调用的指标中记录失败原因。这编译：

               .onFailure()
                   .retry()
                   .withBackOff(Duration.ofMillis(INITIAL_RETRY_DELAY_MS))
                   .until(retryTimeExpired(wrapper))

我正在retryTimeExpired方法中记录指标。但在运行时我得到这个：

Caused by: java.lang.IllegalArgumentException: Invalid retry configuration, `when` cannot be used with a back-off configuration
    at io.smallrye.mutiny.groups.UniRetry.when(UniRetry.java:156)
    at io.smallrye.mutiny.groups.UniRetry.until(UniRetry.java:137)

我当然可以添加sleep，但这是被动的。可能会阻塞一小段时间，但我不想阻塞线程。任何想法如何做到这一点sleep？

Answer 1

您可以尝试使用许多连续onFailure的 s。只要第一个不处理异常（recoverWithItem, recoverWithNull, recoverWithUni）或抛出自己的异常，下一个应该观察到同样的失败。

service.apiMethod(key)
    .invoke(record -> logger.info("Succeeded to read record."))
    .onFailure()
        .invoke(exception -> logger.warn("Failed to read record."))
    .onFailure()
        .retry().withBackOff(delay).indefinitely();