故障保护-超过重试次数时执行一些操作，然后再试一次

Question

我有一个用例，需要调用UPDATE/DELETE Rest endpoint，它可能会返回关于实体被锁定以进行编辑的异常。我想等待实体解锁一段时间，否则调用force unlock endpoint并再次调用我的原始请求。这在故障保护中是可能的吗？

到目前为止我试过：

lockRetryPolicy = new RetryPolicy()
            .retryOn(LockException.class)
            .withBackoff(1, 8, TimeUnit.MINUTES)
            .withMaxDuration(30, TimeUnit.MINUTES);

和

private <R, T> R lockRetryExecution(String elementUrl, Callable<R> task) {
    return Failsafe.with(lockRetryPolicy)
            .onRetriesExceeded((o, throwable) -> {
                forceUnlock(elementUrl);
                task.call();
            })
            .withFallback((o, throwable) -> o)
            .get(task);
}

然而，用这种方法，我必须自己做最后一次“重试”，不能得到这个动作的结果。

Answer 1

看起来这很管用。

private <R, T> R lockRetryExecution(String elementUrl, Callable<R> task) {
    return Failsafe.with(lockRetryPolicy)
        .onRetriesExceeded((o, throwable) -> forceUnlock(elementUrl))
        .withFallback(task)
        .get(task);
}