Resilience4j CircuitBreaker如何为Callable无返回值方法配置Fallback

为什么Consumer/无返回值Callable场景无显式withFallback配置 #

Resilience4j的withFallback API设计核心是「异常/返回值匹配后返回和原方法同类型的结果」，对于无返回值的Runnable、Consumer或者返回Void的Callable，官方没有做专门的语法糖适配，所以在Decorators.ofConsumer()、Decorators.ofCallable()（泛型为Void时）的链式调用中看不到显式的withFallback方法，并非底层能力不支持。

不用修改原方法返回值的实现方案 #

方案1：包装为Callable（无侵入适配现有逻辑） #

不需要修改原有sendMessage的返回值，只需要在包装的Callable中手动返回null即可，完全不影响业务逻辑：

Decorators.ofCallable(() -> {
    sendMessage(primaryJmsTemplate, body);
    return null;
})
// 可根据异常类型做更精细的降级控制，示例为捕获所有异常走降级
.withFallback((Exception e) -> {
    sendMessage(secondaryJmsTemplate, body);
    return null;
})
.withCircuitBreaker(circuitBreaker)
.call();

方案2：CircuitBreaker原生API+异常捕获（逻辑更直观） #

如果不需要复杂的Fallback匹配规则，直接用CircuitBreaker装饰Runnable，手动捕获异常走降级即可：

// 装饰主链路发送逻辑
Runnable primarySend = circuitBreaker.decorateRunnable(() -> sendMessage(primaryJmsTemplate, body));
try {
    primarySend.run();
} catch (Exception e) {
    // 熔断/发送异常时走备机发送
    sendMessage(secondaryJmsTemplate, body);
}

方案3：注解式实现（Spring项目更简洁） #

如果是Spring集成Resilience4j的场景，直接用@CircuitBreaker注解即可，无返回值方法完全兼容，不需要手动包装：

@CircuitBreaker(name = "jms-send-circuit", fallbackMethod = "sendWithSecondary")
public void sendWithPrimary(String body) {
    sendMessage(primaryJmsTemplate, body);
}

// 降级方法，参数列表要和原方法对齐，最后增加异常参数
public void sendWithSecondary(String body, Exception e) {
    sendMessage(secondaryJmsTemplate, body);
}

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