我在基于 Spring Boot Webflux 构建的反应式 Web 服务中使用断路器实现。我在
pom.xml
中使用以下依赖项:
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.4.4</version>
</parent>
...
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-circuitbreaker-reactor-resilience4j</artifactId>
<version>2.0.1</version>
</dependency>
然后我创建了与断路器相关的bean:
@Configuration
public class NetworkProfileCircuitBreakerConfig {
...
@Bean("networkProfileCircuitBreakerFactory")
public ReactiveCircuitBreakerFactory networkProfileCircuitBreakerFactory() {
return new ReactiveResilience4JCircuitBreakerFactory();
}
@Bean
public ReactiveCircuitBreaker networkProfileCircuitBreaker(@Qualifier("networkProfileCircuitBreakerFactory") ReactiveCircuitBreakerFactory factory) {
return factory.create("networkProfileCircuitBreaker");
}
@Bean
public Customizer<ReactiveResilience4JCircuitBreakerFactory> circuitBreakerCustomizer() {
return factory -> {
factory.configureDefault(id -> new Resilience4JConfigBuilder(id)
.circuitBreakerConfig(CircuitBreakerConfig.custom()
.failureRateThreshold(failureRate)
.minimumNumberOfCalls(minimumNumberOfCalls)
.slidingWindowSize(slidingWindowSize)
.enableAutomaticTransitionFromOpenToHalfOpen()
.waitDurationInOpenState(Duration.ofMillis(waitDurationInOpenState))
.ignoreExceptions(BadRequestException.class)
.build())
.timeLimiterConfig(TimeLimiterConfig.custom()
.timeoutDuration(Duration.ofMillis(timeLimiter))
.build())
.build());
factory.addCircuitBreakerCustomizer(circuitBreaker -> circuitBreaker.getEventPublisher()
.onStateTransition(e -> {
switch(e.getStateTransition().getToState()) {
case CLOSED:
log.info("Circuit Breaker is now CLOSED.");
break;
case HALF_OPEN:
log.info("Circuit Breaker is now HALF_OPEN.");
break;
case OPEN:
log.info("Circuit Breaker is now OPEN!");
break;
case METRICS_ONLY:
break;
default:
break;
}
}), "circuitBreakerStateTransitionEvents");
};
}
}
然后我将
ReactiveCircuitBreaker
bean 自动连接到我的服务,以便在我的响应式调用中使用它:
...
@Service
public class NetworkProfileService {
...
@Autowired
private ReactiveCircuitBreaker networkProfileCircuitBreaker;
...
public Mono<ResponseEntity<NetworkProfileResponse>> getNetworkProfile(NetworkProfileRequest request) {
return networkProfileCircuitBreaker.run(adapter.getData(request)
, throwable -> {
//Fallback method
});
}
}
然而,我的
ReactiveResilience4JCircuitBreakerFactory
似乎无法正常工作;断路器似乎使用默认设置而不是我的自定义设置。
我尝试过很多事情,包括将工厂移动到我的 Service
类构造函数;没有效果。
有什么我可能错过的吗?
我遇到了同样的问题,我的解决方法是手动完成(在 buildConfiguration 方法中,您可以添加配置):
@Bean
public ReactiveCircuitBreaker reactiveCircuitBreaker(ReactiveCircuitBreakerFactory reactiveResilience4JCircuitBreakerFactory){
return reactiveResilience4JCircuitBreakerFactory.create("id");
}
@Bean
public ReactiveCircuitBreakerFactory reactiveResilience4JCircuitBreakerFactory() {
ReactiveResilience4JCircuitBreakerFactory reactiveResilience4JCircuitBreakerFactory = new ReactiveResilience4JCircuitBreakerFactory();
reactiveResilience4JCircuitBreakerFactory.configureDefault(buildConfiguration());
return reactiveResilience4JCircuitBreakerFactory;
}
private Function<String, Resilience4JCircuitBreakerConfiguration> buildConfiguration() {
Resilience4JCircuitBreakerConfiguration resilience4JCircuitBreakerConfiguration = new Resilience4JCircuitBreakerConfiguration();
CircuitBreakerConfig breakerConfig = CircuitBreakerConfig
.from(CircuitBreakerConfig.ofDefaults())
.build();
resilience4JCircuitBreakerConfiguration.setCircuitBreakerConfig(breakerConfig);
resilience4JCircuitBreakerConfiguration.setTimeLimiterConfig(TimeLimiterConfig.custom()
.timeoutDuration(Duration.ofMillis(TIMEOUT)).build());
return (id -> resilience4JCircuitBreakerConfiguration);
}
我查看了内部实现,发现它在应用配置时从内部读取配置。不过,当我们使用
entryMap
添加配置或使用 CircuitBreakerRegisty#addConfiguration(String, CircuitBreakerConfiguration)
时,它不会在内部向 Customizer<ReactiveResilience4JCircuitBreakerFactory>
添加配置。这就是我们的配置不起作用的原因。以下解决方案对我有用。我的要求是为不同的路线配备不同配置的断路器。
entryMap