Java 8 родовое Retry, если определенное исключение

Question

я найти себе писать много циклов повторных попыток, которые выглядят как

int triesRemaining = 3; 

    while (triesRemaining > 0) { 
     try { 
      <MY FUNCTION CALL> 
      LOGGER.info("success"); 
      break; 
     } catch (Exception e) { 
      if (e.getCause() instanceof SocketTimeoutException) { 
       triesRemaining--; 
       LOGGER.info(e.getMessage() + " trying again. Tries Remaining: " + triesRemaining); 
      } else { 
       LOGGER.error(e.getMessage(), e); 
       return; 
      } 
     } 
    } 
    if (triesRemaining == 0) { 
     LOGGER.error("Failed over too many times"); 
    } 

Я хочу написать обобщенную функцию, которая принимает Lambda и только повторю на конкретную ошибке (в вышеупомянутый случай - SocketTimeoutException). Я видел некоторые функции, которые принимают Runnable, что хорошо, но они, похоже, не ограничивают определенные исключения.

Любые советы?

Answer 1

Посмотрите на org.springframework.retry

Eсть аннотация @Retryable, соответствующая вашей потребности. Вы можете указать тип исключения для повторной попытки и настроить количество попыток и т. Д.

Answer 2

Ну, это уже сделано. Он также принимает список исключений, на которые вы хотите повторить попытку. Он также обеспечивает линейные/экспоненциальные стратегии повтора. Взгляните https://github.com/rholder/guava-retrying

Простой пример из его ридми, вы можете создавать и использовать retryer как: -

Callable<Boolean> callable = new Callable<Boolean>() { 
public Boolean call() throws Exception { 
    return true; // do something useful here 
}}; 

Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder() 
    .retryIfResult(Predicates.<Boolean>isNull()) 
    .retryIfExceptionOfType(IOException.class) 
    .retryIfRuntimeException() 
    .withStopStrategy(StopStrategies.stopAfterAttempt(3)) 
    .build(); 

try { 
    retryer.call(callable); 
} catch (RetryException e) { 
    e.printStackTrace(); 
} catch (ExecutionException e) { 
    e.printStackTrace(); 
} 

Answer 3

В чем проблема, просто заставьте эту функцию принять аргумент Runnable, а затем запустите его в <MY FUNCTION CALL>?

public static void retry(Runnable r) { 
     // ... 
     while (triesRemaining > 0) { 
     try { 
      r.run(); 
      LOGGER.info("success"); 
      break; 
     } 
     // ... 
} 

затем вызвать его (если вы предпочитаете - с лямбда):

retry(() -> { 
     connectToServer(); 
     // todo what-ever-you-want 
    }); 

Answer 4

Я считаю, что вы ищете для чистого раствора на основе Java. Основываясь на предположении, я бы сказал, что Java 8 использует функциональный интерфейс, интерфейс с единым абстрактным методом. Я бы создал новый класс RetryCommand, который имеет метод , который принимает функцию.

Answer 5

Заканчивать Failsafe:

RetryPolicy retryPolicy = new RetryPolicy() 
    .retryOn(SocketTimeoutException.class) 
    .withMaxRetries(3); 

Failsafe.with(retryPolicy) 
    .onRetry((c, f, ctx) -> log.warn("Failure #{}. Retrying.", ctx.getExecutions())) 
    .onFailure(e -> LOGGER.error(e.getMessage(), e)) 
    .run(() -> myFunctionCall());