使用@CircuitBreaker注解无法触发降级回退问题求助

环境与场景概述 #

• 微服务调用链路：客户端 → API Gateway → serviceA → serviceB → serviceD
• 技术栈：Eureka服务注册中心、Spring Cloud Gateway、Prometheus+Grafana、Docker、Spring Cloud CircuitBreaker
• 版本信息：Spring Cloud 2021.0.5、Spring Boot 2.7.9、JRE 1.8

问题描述 #

在serviceA调用serviceB的方法上使用@CircuitBreaker注解实现熔断逻辑，期望serviceB故障时触发回退方法返回预设内容。但停止serviceB容器测试时，仅收到500状态码，回退逻辑未触发；而使用CircuitBreakerFactory手动实现熔断时，回退逻辑可正常生效。

已尝试措施 #

• 在application.yml中配置多套熔断规则
• 调整Maven依赖版本与内容
• 更换Spring Cloud版本
• 更换JRE版本

可能原因与解决方案 #

1. 注解切面未生效 #

Spring Cloud CircuitBreaker的@CircuitBreaker依赖AOP切面增强，若切面未生效会导致注解失效。

• 解决方式：
  • 确保service类添加@Service/@Component注解，被Spring容器扫描管理；
  • 在项目启动类上添加@EnableCircuitBreakers注解，开启熔断注解的支持（Spring Cloud 2021版本必须显式声明）。

2. 类内部方法调用拦截失效 #

如果调用带@CircuitBreaker注解的方法是同一个类内的其他方法，Spring AOP动态代理无法拦截内部调用，导致注解不生效。

• 解决方式：
  • 通过Spring容器注入自身bean，使用代理对象调用注解方法；
  • 或通过AopContext.currentProxy()获取代理对象后调用，示例：

    public String innerCall() {
        return ((ServiceAServiceImplementation) AopContext.currentProxy()).callServiceB();
    }
    

3. 依赖缺失或不兼容 #

若缺少对应熔断实现的starter依赖，注解逻辑无法正常加载。

• 解决方式：
  确认pom.xml中引入对应熔断实现的starter，以Resilience4j为例：

  <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
  </dependency>
  

4. 注解与配置未绑定 #

@CircuitBreaker的name属性需与application.yml中的配置key一致，否则配置不生效，熔断逻辑无法触发。

• 解决方式：
  注解与yml配置示例：

  @CircuitBreaker(name = "serviceBCircuit", fallbackMethod = "serviceBFallback")
  public String callServiceB() {
      return restTemplate.getForObject("http://serviceB/api/test", String.class);
  }
  

  spring:
    cloud:
      circuitbreaker:
        resilience4j:
          serviceBCircuit:
            circuitbreaker:
              failure-rate-threshold: 50
              wait-duration-in-open-state: 10s
  

代码示例 #

@CircuitBreaker注解实现（原失效代码） #

@Service
public class ServiceAServiceImplementation {

    @Autowired
    private RestTemplate restTemplate;

    @CircuitBreaker(name = "serviceB", fallbackMethod = "serviceBFallback")
    public String callServiceB() {
        return restTemplate.getForObject("http://serviceB/api/test", String.class);
    }

    public String serviceBFallback(Throwable throwable) {
        return "Service B 暂时不可用，已触发回退";
    }
}

CircuitBreakerFactory实现（正常生效代码） #

@Service
public class ServiceAServiceImplementation {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private CircuitBreakerFactory circuitBreakerFactory;

    public String callServiceBWithFactory() {
        return circuitBreakerFactory.create("serviceB")
                .run(() -> restTemplate.getForObject("http://serviceB/api/test", String.class),
                        throwable -> "Service B 暂时不可用，已触发回退");
    }
}

serviceA的pom.xml关键依赖 #

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>2021.0.5</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

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