如何使用Resilience4J API为动态创建的断路器注册降级方法？

无返回值场景（适配你的Runnable代码） #

直接通过Try的异常处理链嵌入降级逻辑，当断路器触发熔断、执行异常时，自动执行兜底方法：

CircuitBreaker circuitBreaker = circuitBreakerRegistry.circuitBreaker(generateNameBasedOnInputArgumets());
Runnable decoratedRunnable = CircuitBreaker.decorateRunnable(circuitBreaker, () -> executeSomeCode());

// 执行并处理降级
Try.runRunnable(decoratedRunnable)
    .onFailure(e -> {
        // 调用自定义降级方法
        myFallbackMethod(e);
    })
    // 如需将异常向上抛出则保留此行；仅需执行降级逻辑可移除
    .getOrElseThrow(e -> new RuntimeException(e));

有返回值场景（业务逻辑需返回结果） #

如果业务逻辑有返回值，改用Supplier结合decorateSupplier，通过recover方法指定兜底结果：

CircuitBreaker circuitBreaker = circuitBreakerRegistry.circuitBreaker(generateNameBasedOnInputArgumets());
Supplier<YourResultType> decoratedSupplier = CircuitBreaker.decorateSupplier(circuitBreaker, () -> executeReturningCode());

YourResultType result = Try.ofSupplier(decoratedSupplier)
    .recover(e -> myFallbackMethodWithReturn(e))
    .get();

降级方法示例 #

根据场景定义对应降级逻辑：

// 无返回值的降级方法
private void myFallbackMethod(Throwable throwable) {
    // 兜底操作：记录异常、执行默认流程、通知监控等
    log.error("断路器触发降级", throwable);
    // 比如读取本地缓存、执行默认业务逻辑
}

// 有返回值的降级方法
private YourResultType myFallbackMethodWithReturn(Throwable throwable) {
    log.error("断路器触发降级", throwable);
    // 返回默认结果或缓存数据
    return new YourResultType("默认值");
}

核心逻辑说明 #

动态创建的断路器不会像注解式那样通过AOP自动绑定降级方法，需要手动通过Try类的API捕获断路器抛出的异常（包括熔断时的CallNotPermittedException、业务代码自身异常），在异常处理分支中触发降级逻辑。

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