Spring Retry — как справиться с ошибками

В мире микросервисов у нас есть сервисы, разговаривающие друг с другом. Один из способов общения — синхронный . Однако в мире облачных вычислений факт заключается в том, что мы не можем избежать сбоев в работе сети, временного простоя службы (из-за перезапуска или сбоя; не более нескольких секунд). Когда клиентам нужны данные в реальном времени и ваша нисходящая служба не отвечает мгновенно, это может повлиять на пользователей, поэтому вам следует создать механизм повторных попыток. Есть много вариантов решения, доступных в Java. Я собираюсь рассказать о Spring Retry в этом блоге. Мы создадим небольшое приложение и посмотрим, как работает Spring Retry. Прежде чем мы начнем, давайте сначала разберемся с некоторыми основами  шаблона Retry :

• Повторите попытку только в том случае, если вы считаете, что она может соответствовать вашим требованиям. Вы не должны использовать его для каждого варианта использования. Это то, что вы строите не с самого начала, а на основе того, что вы узнали во время разработки или тестирования. Например, при тестировании вы можете обнаружить, что при обращении к ресурсу он работает один раз, но в следующий раз выдает ошибку тайм-аута, а затем работает снова при повторном обращении. После проверки с последующей системой вы не сможете найти причину или решение. Возможно, вы захотите создать функцию Retry для обработки стороны вашего приложения, но первая попытка должна заключаться в исправлении нисходящей стороны. Не прыгайте быстро, чтобы найти решение с вашей стороны.

• Повторная попытка может привести к засорению ресурсов и ухудшению ситуации, препятствуя восстановлению приложения; следовательно, количество повторных попыток должно быть ограничено. Вы должны попытаться начать с минимального счета, такого как 3, и не превышать 5 или около того.

• Повторить не следует делать для каждого исключения. Это должно быть закодировано только для определенного типа исключения. Например, вместо размещения кода вокруг Exception.class, сделайте это для SQLException.class.

• Повторная попытка может привести к тому, что несколько потоков будут пытаться получить доступ к одному и тому же общему ресурсу, и блокировка может стать большой проблемой. Алгоритм экспоненциального отката должен применяться для постоянного увеличения задержки между попытками, пока вы не достигнете максимального предела.

• При применении Retry идемпотентность должна быть обработана. Повторный запуск одного и того же запроса не должен инициировать повторную транзакцию в системе.

Теперь давайте создадим простой сервис, демонстрирующий, как Spring Retry помогает справиться с Retry.

Предпосылки

• Spring Boot 2.1.x

• Gradle

• Visual Studio Code / Eclipse

Зависимости Gradle

dependencies {
 implementation('org.springframework.boot:spring-boot-starter-web')
 implementation('org.springframework.retry:spring-retry')
 implementation('org.springframework.boot:spring-boot-starter-aop')

 testImplementation('org.springframework.boot:spring-boot-starter-test')
}

@EnableRetry
@SpringBootApplication
public class DemoApplication {

 public static void main(String[] args) {
  SpringApplication.run(DemoApplication.class, args);
 }
}

@Service
public class BillingService {
    private static final Logger LOGGER = LoggerFactory.getLogger(BillingService.class);
    int counter =0;

    @Retryable(value = { SQLException.class }, maxAttempts = 3)
    public String simpleRetry() throws SQLException {
        counter++;
        LOGGER.info("Billing Service Failed "+ counter);
        throw new SQLException();

    }

    @Recover
    public String recover(SQLException t){
        LOGGER.info("Service recovering");
        return "Service recovered from billing service failure.";
    }
}   

@RestController
@RequestMapping(value="/billing")
public class BillingClientService {

    @Autowired
    private BillingService billingService;
    @GetMapping
    public String callRetryService() throws SQLException {
        return billingService.simpleRetry();
    }
}

2018-11-16 09:59:51.399  INFO 17288 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Billing Service Failed 1
2018-11-16 09:59:52.401  INFO 17288 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Billing Service Failed 2
2018-11-16 09:59:53.401  INFO 17288 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Billing Service Failed 3
2018-11-16 09:59:53.402  INFO 17288 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Service recovering

  @Retryable(value = { SQLException.class }, maxAttempts = 3, backoff = @Backoff(delay = 5000))
    public String simpleRetry() throws SQLException {
        counter++;
        LOGGER.info("Billing Service Failed "+ counter);
        throw new SQLException();

    }

2018-11-17 23:02:12.491  INFO 53392 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Billing Service Failed 1
2018-11-17 23:02:17.494  INFO 53392 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Billing Service Failed 2
2018-11-17 23:02:22.497  INFO 53392 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Billing Service Failed 3
2018-11-17 23:02:22.497  INFO 53392 --- [nio-8080-exec-1] c.e.springretrydemo.BillingService       : Service recovering