Spring Boot 2调用Servlet时Resilience4j @CircuitBreaker不触发问题

核心原因 #

Resilience4j的@CircuitBreaker触发的前提是：方法执行时抛出了注解配置中指定的异常，且方法调用经过了Spring AOP代理。你遇到的问题大概率是HttpClient或WebClient的调用没有抛出@CircuitBreaker能识别的异常，或者异步调用导致异常没有被正确传递到注解所在的方法层面。

具体解决步骤 #

1. 确保WebClient调用抛出异常 #

WebClient默认在收到4xx/5xx响应时不会主动抛出异常，需要显式配置错误处理逻辑，让它将错误响应转为异常，这样@CircuitBreaker才能捕获到：

// 示例WebClient全局配置，统一处理错误响应
WebClient webClient = WebClient.builder()
    .defaultStatusHandler(HttpStatus::isError, response -> {
        return response.bodyToMono(String.class)
            .flatMap(body -> Mono.error(new RuntimeException("请求失败，状态码: " + response.statusCode() + ", 响应体: " + body)));
    })
    .build();

或者在单次调用时指定错误处理：

webClient.get()
    .uri("你的Servlet地址")
    .retrieve()
    .onStatus(HttpStatus::isError, response -> Mono.error(new HttpClientErrorException(response.statusCode())))
    .bodyToMono(String.class)
    .block(); // 同步调用需block；异步场景确保异常能传递到外层方法

2. 确保HttpClient调用抛出异常 #

如果使用Apache HttpClient等实现，需手动判断响应状态并抛出异常，默认的连接超时、IO异常会被抛出，但4xx/5xx响应需要主动处理：

CloseableHttpClient httpClient = HttpClients.createDefault();
HttpGet request = new HttpGet("你的Servlet地址");
try (CloseableHttpResponse response = httpClient.execute(request)) {
    int statusCode = response.getStatusLine().getStatusCode();
    if (statusCode >= 400) {
        throw new HttpClientErrorException(HttpStatus.valueOf(statusCode), "请求失败");
    }
    // 处理正常响应
} catch (IOException e) {
    throw new RuntimeException(e); // 确保异常被抛出到外层方法
}

3. 处理异步调用的异常传递 #

如果WebClient是异步调用（返回Mono/Flux），需添加resilience4j-reactor依赖以支持响应式类型的熔断，并确保注解方法直接返回响应式对象：

<!-- Maven依赖示例 -->
<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-reactor</artifactId>
    <version>${resilience4j.version}</version>
</dependency>

对应方法实现：

@CircuitBreaker(name = "servletCall", fallbackMethod = "servletFallback")
public Mono<String> callServletAsync() {
    return webClient.get()
        .uri("你的Servlet地址")
        .retrieve()
        .onStatus(HttpStatus::isError, response -> Mono.error(new RuntimeException("异步请求失败")))
        .bodyToMono(String.class);
}

// 对应的降级方法
private Mono<String> servletFallback(Throwable throwable) {
    return Mono.just("降级响应内容");
}

4. 确认AOP代理生效（排除内部调用问题） #

Spring AOP默认不拦截同一类内的内部方法调用，如果你是在同一服务类的内部方法中调用带@CircuitBreaker的方法，需要通过代理对象调用：

• 将调用逻辑拆分到另一个Bean，通过依赖注入调用
• 或在当前Bean中自注入自身（获取代理对象）
• 启用expose-proxy=true，通过AopContext.currentProxy()获取代理对象

示例（自注入方式）：

@Service
public class YourService {
    @Autowired
    private YourService selfProxy; // 注入代理后的自身对象

    public void outerMethod() {
        // 通过代理对象调用，触发@CircuitBreaker
        selfProxy.callServletWithHttpClient();
    }

    @CircuitBreaker(name = "servletCall", fallbackMethod = "fallback")
    public void callServletWithHttpClient() {
        // HttpClient调用逻辑
    }
}

5. 检查@CircuitBreaker的异常配置 #

确认注解的includeExceptions/ignoreExceptions参数包含了你抛出的异常类型，默认会捕获所有Throwable，但自定义配置时需注意：

// 明确指定需要熔断的异常类型
@CircuitBreaker(name = "servletCall", fallbackMethod = "fallback", include = {RuntimeException.class, IOException.class})

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