java - 如何在 Resilience4j Spring starter 中配置事件

Question

我已经通过 resilience4j circuitbreaker factory bean 进行了配置，如下所示。但是我无法获得 ovveride 事件监听器示例的功能以打开、关闭等。请帮忙

@Bean
public Customizer<Resilience4JCircuitBreakerFactory> globalCustomConfiguration() {
    CircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig.custom()
            .failureRateThreshold(Float.parseFloat(failureRateThreshold))
            .waitDurationInOpenState(Duration.ofMillis(Long.parseLong(waitDurationInOpenState)))
            .slidingWindowSize(Integer.parseInt(slidingWindowSize)).build();
    TimeLimiterConfig timeLimiterConfig = TimeLimiterConfig.custom()
            .timeoutDuration(Duration.ofSeconds(Long.parseLong(timelimiterDuration))).build();

    // the circuitBreakerConfig and timeLimiterConfig objects
    return factory -> factory.configureDefault(id -> new Resilience4JConfigBuilder(id)
            .timeLimiterConfig(timeLimiterConfig).circuitBreakerConfig(circuitBreakerConfig).build());
}

Answer 1

我推荐使用resilience4j-spring-boot2。它提供了许多功能，如注释支持、外部配置、指标等等 -> https://resilience4j.readme.io/docs/getting-started-3

我们的 starter 支持以下内容:

您可以添加一个 RegistryEventConsumer bean，以便将事件消费者添加到新创建的实例中。例如，您可以将 RegistryEventConsumer 添加到 CircuitBreakerRegistry，以便将日志记录事件使用者注册到每个新创建的 CircuitBreaker 实例。

@Bean
public RegistryEventConsumer<CircuitBreaker> myRegistryEventConsumer() {

    return new RegistryEventConsumer<CircuitBreaker>() {
        @Override
        public void onEntryAddedEvent(EntryAddedEvent<CircuitBreaker> entryAddedEvent) {
            entryAddedEvent.getAddedEntry().getEventPublisher().onEvent(event -> LOG.info(event.toString()));
        }

        @Override
        public void onEntryRemovedEvent(EntryRemovedEvent<CircuitBreaker> entryRemoveEvent) {

        }

        @Override
        public void onEntryReplacedEvent(EntryReplacedEvent<CircuitBreaker> entryReplacedEvent) {

        }
    };
}