Все самое полезное для Java-разработчика в одном канале.
Учиться у нас: clc.to/AATM8w
Для обратной связи: @proglibrary_feeedback_bot
По рекламе: @tproger_sales_bot
РКН: https://gosuslugi.ru/snet/67a5bbda1b17b35b6c1a55c4
Post #7494
2.4K
🔧 Spring Retry: повторные попытки с backoff без ручных циклов
Retry-логика руками — источник багов. Неправильный backoff создаёт thundering herd. Spring Retry решает это декларативно.
🔹 Решение
▪️ Зависимость
▪️ Включение и базовое использование
▪️ Программная конфигурация для сложных случаев
▪️ Интеграция с Circuit Breaker
Retry отрабатывает до Circuit Breaker. Ошибки после всех попыток засчитываются как один сбой в Circuit Breaker — корректное поведение.
random = true в @Backoff добавляет jitter — случайное смещение задержки. Без jitter все инстансы приложения, получившие ошибку одновременно, будут ретраить синхронно, создавая пики нагрузки на восстанавливающийся сервис. Jitter разбивает пики.
⚠️ Ретраить нужно только идемпотентные операции. POST с созданием ресурса без идемпотентного ключа при ретрае создаст дубликаты. Либо добавить Idempotency-Key заголовок, либо не ретраить.
══════ Навигация ══════
Вакансии • Задачи • Собесы
🐸 Библиотека джависта
#Enterprise
Retry-логика руками — источник багов. Неправильный backoff создаёт thundering herd. Spring Retry решает это декларативно.
🔹 Решение
▪️ Зависимость
<dependency>
<groupId>org.springframework.retry</groupId>
<artifactId>spring-retry</artifactId>
</dependency>
▪️ Включение и базовое использование
@Configuration
@EnableRetry
public class RetryConfig { }
@Service
public class ExternalApiService {
@Retryable(
retryFor = {IOException.class, HttpServerErrorException.class},
noRetryFor = {HttpClientErrorException.class}, // 4xx не ретраим
maxAttempts = 4,
backoff = @Backoff(
delay = 1000,
multiplier = 2,
maxDelay = 10000,
random = true // jitter для предотвращения thundering herd
)
)
public ApiResponse callExternalApi(ApiRequest request) {
return restClient.post()
.uri("/api/endpoint")
.body(request)
.retrieve()
.body(ApiResponse.class);
}
@Recover
public ApiResponse recover(IOException e, ApiRequest request) {
log.error("All retry attempts exhausted for request: {}", request.getId(), e);
// fallback логика или выброс бизнес-исключения
throw new ExternalServiceUnavailableException(request.getId(), e);
}
}
▪️ Программная конфигурация для сложных случаев
@Bean
public RetryTemplate retryTemplate() {
return RetryTemplate.builder()
.maxAttempts(5)
.exponentialBackoff(1000, 2, 30000)
.retryOn(IOException.class)
.withListener(new RetryListenerSupport() {
@Override
public <T, E extends Throwable> void onError(RetryContext ctx,
RetryCallback<T, E> cb,
Throwable t) {
log.warn("Retry attempt {} failed: {}",
ctx.getRetryCount(), t.getMessage());
}
})
.build();
}
▪️ Интеграция с Circuit Breaker
@CircuitBreaker(name = "externalApi", fallbackMethod = "circuitFallback")
@Retryable(retryFor = IOException.class, maxAttempts = 3)
public ApiResponse callWithProtection(ApiRequest request) {
return callExternalApi(request);
}
Retry отрабатывает до Circuit Breaker. Ошибки после всех попыток засчитываются как один сбой в Circuit Breaker — корректное поведение.
random = true в @Backoff добавляет jitter — случайное смещение задержки. Без jitter все инстансы приложения, получившие ошибку одновременно, будут ретраить синхронно, создавая пики нагрузки на восстанавливающийся сервис. Jitter разбивает пики.
⚠️ Ретраить нужно только идемпотентные операции. POST с созданием ресурса без идемпотентного ключа при ретрае создаст дубликаты. Либо добавить Idempotency-Key заголовок, либо не ретраить.
══════ Навигация ══════
Вакансии • Задачи • Собесы
🐸 Библиотека джависта
#Enterprise
- ❤ 7
- 👍 6
- 🔥 1
