Как реализовать экспоненциальную задержку/сон для проб и уловов

Я пытаюсь написать другой декоратор, такой как RetriableProcessorDecorator ниже (как отдельный класс), чтобы это делает экспоненциальную задержку при повторной попытке. Например, если сообщение не может быть обработано, мы ждем 1 секунду (должно быть настроено), затем 2 секунды, затем 4 секунды, затем 8 секунд, затем 16 секунд и т. д. Я бы хотел использовать поток вместо ожидания занятости, поскольку это дешевле . Я написал новый класс RetriableProcessorExponentialDecorator, который делает это, но я не уверен, что это правильный подход.

RetriableProcessorDecorator.java:

@Slf4j
@Setter
@RequiredArgsConstructor
@AllArgsConstructor(access = AccessLevel.PACKAGE)
public class RetriableProcessorDecorator implements.   
AbsMessageProcessorDecorator {
private final AbsMessageProcessor messageProcessor;
@Autowired
private AbsMessageActiveMQConfiguration configuration;

@Override
public void onMessage(AbsMessage message) throws Exception {
    int executionCounter = 0;
    final int maxRetries = this.configuration.getExceptionRetry() + 1;
    do {
        executionCounter++;
        try {
            this.messageProcessor.onMessage(message);
        } catch (RetriableException e) {
            log.info("Failed to process message. Retry #{}", executionCounter);
        } catch (Exception e) {
            // We don't retry on this, only RetriableException.
            throw e;
        }
    } while (executionCounter < maxRetries);
}
}

RetriableProcessorExponentialDecorator.java (новый класс, который я реализую):

public class RetriableProcessorExponentialDecorator implements AbsMessageProcessorDecorator {
  private final AbsMessageProcessor messageProcessor;
  @Autowired
  private AbsMessageActiveMQConfiguration configuration;

  @Override
  public void onMessage(AbsMessage message) throws Exception {
    int executionCounter = 0;
    int delayCounter = 1000;
    final int maxRetries = this.configuration.getExceptionRetry() + 1;
    do {
      executionCounter++;
      try {
        this.messageProcessor.onMessage(message);
      } catch (RetriableException e) {
        log.info("Failed to process message. Retry #{}", executionCounter);
        Thread.sleep(delayCounter);
        delayCounter = delayCounter * 2;
      } catch (Exception e) {
        // We don't retry on this, only RetriableException.
        throw e;
      }
    } while (executionCounter < maxRetries && delayCounter < Long.MAX_VALUE);
  }
}
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
0
0
1 802
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

В целом я думаю, что ваш подход в порядке.

Однако, если вы хотите сделать его настраиваемым (то есть более полезным), вы можете сделать что-то вроде:

double multiplier = 2.0; // make this configurable
...
delayCounter = (long) (delayCounter * (Math.pow(multiplier, executionCounter)));
Thread.sleep(delayCounter);

Вы также можете добавить способ настроить максимальную задержку, что может быть удобно для некоторых случаев использования, например:

long maxDelay = 300000; // 5 minutes
...
if (delayCounter > maxDelay) {
   delayCounter = maxDelay;
}
Thread.sleep(delayCounter);

Спасибо за предложение!

louprogramming 06.02.2019 19:07

Вам не нужно умножать на delayCounter ; двойная задержка = Math.pow(MULTIPLIER, retryCounter++);

abbas 04.03.2020 13:12

Другие вопросы по теме