Я путаюсь с CircuitBreaker, используя WebClient. Когда зависимый сервис не работает, резерв не выполняется.
Нужна ли дополнительная настройка?
Для CircuitBreaker с использованием RestTemplate это работает без дальнейшей настройки. Смотрите мой пример кода здесь: https://github.com/altfatterz/resilience4j-demo
Вот мой пример
@GetMapping("/")
public Mono<String> hello() {
return webClient.build()
.get().uri(uriBuilder -> uriBuilder
.scheme("http")
.host("slow-service").path("/slow")
.build())
.retrieve().bodyToMono(String.class).transform(it -> {
CircuitBreaker cb = circuitBreakerFactory.create("slow");
return cb.run(() -> it, throwable -> Mono.just("fallback"));
});
}
с использованием следующей конфигурации:
@Bean
public Customizer<ReactiveResilience4JCircuitBreakerFactory> defaultCustomizer() {
return factory -> factory.configureDefault(id -> new Resilience4JConfigBuilder(id)
.circuitBreakerConfig(ofDefaults())
.timeLimiterConfig(TimeLimiterConfig.custom().timeoutDuration(Duration.ofSeconds(3)).build()).build());
}
@Bean
@LoadBalanced
public WebClient.Builder webClient() {
return WebClient.builder();
}