简介
Spring Cloud 断路器提供了不同断路器实现之间的抽象。它提供了在应用程序中使用的一致API，让开发人员选择最适合应用程序需求的断路器实现。
Spring Cloud支持以下断路器实现:
- Resilience4J
- Sentinel
- Spring Retry
阻塞式应用
要在代码中创建断路器，可以使用CircuitBreakerFactory API。当你在类路径中包含Spring Cloud Circuit Breaker starter时，将自动为你创建实现此API的bean。下面的例子展示了如何使用这个API的一个简单例子:
org.springframework.cloud
spring-cloud-starter-circuitbreaker-resilience4j
或者（反应式）
org.springframework.cloud
spring-cloud-starter-circuitbreaker-reactor-resilience4j
简单API应用
@Service
public static class UsersService {
private RestTemplate rest;
private CircuitBreakerFactory cbFactory;
public DemoControllerService(RestTemplate rest, CircuitBreakerFactory cbFactory) {
this.rest = rest;
this.cbFactory = cbFactory;
}
public Users getUser() {
// 这里remoteUser是唯一标识，下面你会看到为这id配置
return cbFactory.create("remoteUser").run(() -> rest.getForObject("/100", Users.class), throwable -> "用户用户信息失败");
}
}CircuitBreakerFactory.create API创建一个名为CircuitBreaker的类实例。run方法接受一个Supplier和一个Function。Supplier是你要包装在断路器中的代码。Function是在断路器跳闸时运行的后备功能。Function被传递导致触发回退的Throwable。如果你不想提供一个回退，你可以选择排除它。
反应式应用
如果Project Reactor位于类路径上，你还可以为响应式代码使用ReactiveCircuitBreakerFactory。下面的例子展示了如何做到这一点:
@Service
public static class DemoControllerService {
private ReactiveCircuitBreakerFactory cbFactory;
private WebClient webClient;
public DemoControllerService(WebClient webClient, ReactiveCircuitBreakerFactory cbFactory) {
this.webClient = webClient;
this.cbFactory = cbFactory;
}
public Mono getUser() {
return webClient.get().uri("/100").retrieve().bodyToMono(Users.class).transform(
it -> cbFactory.create("remoteUser").run(it, throwable -> return Mono.just("获取用户失败")));
}
} ReactiveCircuitBreakerFactory.create API创建一个名为ReactiveCircuitBreaker的类实例。run方法将一个Mono或Flux包在一个断路器中。你可以选择配置一个回退函数，该函数将在断路器被触发并传递导致故障的Throwable时被调用。
配置
你可以通过创建Customizer类型的bean来配置断路器工厂。Customizer接口有一个方法(称为customize)
// 对断路器工厂进行自定义
@Component
public class PackCircuitBreakerCustomizer implements Customizer {
@Override
public void customize(Resilience4JCircuitBreakerFactory tocustomize) {
tocustomize.configure(builder -> {
// 配置超时
builder.timeLimiterConfig(
TimeLimiterConfig.custom()
.timeoutDuration(Duration.ofMillis(3000))
.build()
) ;
// 配置熔断
builder.circuitBreakerConfig(
CircuitBreakerConfig.custom()
.failureRateThreshold(0.1f) // 当故障率大于等于故障阈值时，断路器切换到开路状态，开始短路调用。
.minimumNumberOfCalls(3) // 断路器打开的前提是至少有3次的调用
.build()
) ;
}, "a1", "a2", "a3", "remoteUser") ;// 这里指定了只有哪些id都会被应用这些配置
// 为所有的断路器提供默认配置
tocustomize.configureDefault(id -> new Resilience4JConfigBuilder(id)
.circuitBreakerConfig(CircuitBreakerConfig.ofDefaults())
.timeLimiterConfig(TimeLimiterConfig.ofDefaults()).build());
}
} 有关如何自定义给定实现的详细信息，请参阅以下文档:
Resilience4J：
https://docs.spring.io/spring-cloud-commons/spring-cloud-circuitbreaker/current/reference/html/spring-cloud-circuitbreaker.html#configuring-resilience4j-circuit-breakers
Sentinel:
https://github.com/alibaba/spring-cloud-alibaba/blob/2.2.x/spring-cloud-alibaba-docs/src/main/asciidoc/circuitbreaker-sentinel.adoc#circuit-breaker-spring-cloud-circuit-breaker-with-sentinel%E2%80%94%E2%80%8Bconfiguring-sentinel-circuit-breakers
Spring Retry:
https://docs.spring.io/spring-cloud-circuitbreaker/docs/current/reference/html/spring-cloud-circuitbreaker.html#configuring-spring-retry-circuit-breakers
一些 CircuitBreaker 实现，如Resilience4JCircuitBreaker，在每次调用CircuitBreaker#run时调用自定义方法。它可能是低效的。在这种情况下，你可以使用CircuitBreaker#once方法。
下面的例子展示了io.github.resilience4j.circuitbreaker.CircuitBreaker的方法。断路器消耗事件。
Customizer.once(circuitBreaker -> {
circuitBreaker.getEventPublisher()
.onStateTransition(event -> log.info("{}: {}", event.getCircuitBreakerName(), event.getStateTransition()));
}, CircuitBreaker::getName)完毕！！！
