如何在Camel路由中记录Resilience4j触发fallback的具体原因

Resilience4j的断路器、舱壁、超时限制三类组件触发熔断/降级时，都会抛出对应类型的专属异常，Camel的Resilience4j组件会把触发fallback的根异常存放在Exchange上下文里，直接取出判断即可定位原因，具体实现如下：

1. 先明确各组件对应的触发异常类型 #

不同容错规则触发时抛出的异常完全不同，可以直接通过异常类型区分触发源：

• 断路器熔断触发：抛出CallNotPermittedException，异常实例携带断路器名称、当前状态（OPEN/HALF_OPEN）等元信息
• 舱壁限流触发：信号量模式舱壁抛出BulkheadFullException，线程池模式舱壁抛出ThreadPoolBulkheadFullException
• 超时限制触发：抛出TimeoutException，异常实例携带对应TimeLimiter的配置信息
• 业务本身报错触发：就是下游调用、业务逻辑抛出的常规业务异常，不属于容错组件主动触发降级

2. Camel路由具体实现代码 #

Camel Resilience4j组件会把触发fallback的原始根异常存在Exchange的CamelResilience4jFallbackException属性中，在fallback流程里直接读取该属性做判断即可，示例代码：

// 路由配置示例
from("direct:invokeDownstream")
    .circuitBreaker()
        // 原有Resilience4j配置：断路器、舱壁、超时参数都保持你原来的配置不变
        .resilience4jConfiguration()
            .circuitBreakerRef("customCircuitBreaker")
            .bulkheadRef("customBulkhead")
            .timeLimiterRef("customTimeLimiter")
            .timeoutEnabled(true)
        .end()
        // 原有业务调用逻辑
        .to("http://downstream-service/api")
    .onFallback()
        .process(exchange -> {
            // 取出触发fallback的根异常
            Exception fallbackCause = exchange.getProperty(
                "CamelResilience4jFallbackException",
                Exception.class
            );

            String triggerReason;
            // 按异常类型匹配触发源
            if (fallbackCause instanceof CallNotPermittedException) {
                CallNotPermittedException cbEx = (CallNotPermittedException) fallbackCause;
                triggerReason = String.format(
                    "断路器触发，断路器名：%s，当前状态：%s",
                    cbEx.getCausingCircuitBreakerName(),
                    cbEx.getCausingCircuitBreakerState()
                );
            } else if (fallbackCause instanceof BulkheadFullException 
                    || fallbackCause instanceof ThreadPoolBulkheadFullException) {
                triggerReason = "舱壁触发，并发/线程数已达配置的最大阈值";
            } else if (fallbackCause instanceof TimeoutException) {
                triggerReason = "超时触发，请求执行时长超过TimeLimiter配置阈值";
            } else {
                triggerReason = String.format(
                    "业务异常触发，异常类型：%s，异常信息：%s",
                    fallbackCause.getClass().getName(),
                    fallbackCause.getMessage()
                );
            }

            // 打印日志记录原因，可按需追加MDC、指标埋点
            log.warn("Fallback执行，触发原因：{}", triggerReason, fallbackCause);
            
            // 原有fallback返回逻辑
            exchange.getMessage().setBody(buildDefaultFallbackResp(triggerReason));
        })
    .end();

如果你用XML方式配置Camel路由，逻辑完全一致：在fallback节点下挂载自定义处理器，从Exchange中读取上述属性做判断即可，不需要修改原有容错配置。

3. 避坑说明 #

• 不要读取Exchange的CamelExceptionCaught属性取异常，这个属性可能被路由中的其他处理器覆盖，必须使用CamelResilience4jFallbackException获取容错流程的原始根异常
• 导入异常类时注意包路径，必须是io.github.resilience4j对应模块下的异常类，不要和其他框架的同名异常混淆，否则类型判断会失效
• 如果出现多异常叠加的场景（比如请求超时同时舱壁占满），Resilience4j会保留最原始的触发异常作为根异常，按上述逻辑判断不会出现误判
• 如果需要更细的排查信息，可以在记录日志时同步打印断路器当前失败率、舱壁剩余可用并发数等Resilience4j实时指标，方便定位根因

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