自定义resilience4j.yml配置读取及断路器未触发fallback问题咨询

核心排查与修复步骤 #

1. 修正YAML配置缩进错误 #

YAML对缩进敏感，你提供的配置中serviceA下的属性未缩进，导致Spring无法正确解析。修正后的配置如下：

resilience4j:
  circuitbreaker:
    instances:
      serviceA:
        eventConsumerBufferSize: 3
        failureRateThreshold: 50
        minimumNumberOfCalls: 2
        automaticTransitionFromOpenToHalfOpenEnabled: true
        waitDurationInOpenState: 5s
        permittedNumberOfCallsInHalfOpenState: 3
        slidingWindowSize: 10
        slidingWindowType: TIME_BASED

2. 确保自定义YAML文件被Spring加载 #

如果配置文件不是默认的application.yml（比如命名为resilience4j.yml），可通过以下方式加载：

• 方式一：自定义配置类加载
  在配置类或启动类上添加注解，配合YAML解析工厂：

  @Configuration
  @PropertySource(value = "classpath:resilience4j.yml", factory = YamlPropertySourceFactory.class)
  public class Resilience4jConfig {
      static class YamlPropertySourceFactory implements PropertySourceFactory {
          @Override
          public PropertySource<?> createPropertySource(String name, EncodedResource resource) throws IOException {
              YamlPropertiesFactoryBean factory = new YamlPropertiesFactoryBean();
              factory.setResources(resource.getResource());
              Properties properties = factory.getObject();
              return new PropertiesPropertySource(name != null ? name : resource.getResource().getFilename(), properties);
          }
      }
  }
  

• 方式二：使用Profile激活
  将配置文件命名为application-resilience4j.yml，然后在application.yml中添加：

  spring:
    profiles:
      active: resilience4j
  

3. 修正Fallback方法签名 #

Fallback方法的参数列表必须与被注解方法完全匹配，或额外添加Throwable参数。你的runCommands方法有String参数，调整Fallback方法如下：

public void ContactsServiceDown(String val) {
    System.out.println("service down");
}
// 或带异常参数便于排查
public void ContactsServiceDown(String val, Throwable throwable) {
    System.out.println("service down: " + throwable.getMessage());
}

4. 确认依赖完整性 #

确保项目引入Resilience4J和Spring AOP依赖（以Maven为例）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-spring-boot2</artifactId>
    <version>你的版本号</version>
</dependency>

验证配置加载状态 #

注入CircuitBreakerRegistry，启动后打印配置信息确认是否生效：

@Autowired
private CircuitBreakerRegistry circuitBreakerRegistry;

@PostConstruct
public void verifyCircuitBreakerConfig() {
    CircuitBreaker circuitBreaker = circuitBreakerRegistry.find("serviceA")
            .orElseThrow(() -> new IllegalArgumentException("未找到serviceA的断路器配置"));
    CircuitBreakerConfig config = circuitBreaker.getCircuitBreakerConfig();
    System.out.println("失败率阈值：" + config.getFailureRateThreshold());
    System.out.println("最小调用次数：" + config.getMinimumNumberOfCalls());
}

内容的提问来源于stack exchange，提问作者Vivekann