Spring Boot ReactiveCircuitBreaker 配置不起作用

问题描述

我在基于 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);
  }