大数跨境
0
0

断路器在项目中的重要性:保护远程接口调用的稳定运行

断路器在项目中的重要性:保护远程接口调用的稳定运行 Spring全家桶实战案例
2023-11-05
0
导读:断路器在项目中的重要性:保护远程接口调用的稳定运行

环境:SpringBoot2.4.12 + Spring Cloud Hoxton.SR12


简介

Spring Cloud 断路器提供了不同断路器实现之间的抽象。它提供了在应用程序中使用的一致API,让开发人员选择最适合应用程序需求的断路器实现。

Spring Cloud支持以下断路器实现:

  • Resilience4J

  • Sentinel

  • Spring Retry

阻塞式应用

要在代码中创建断路器,可以使用CircuitBreakerFactory API。当你在类路径中包含Spring Cloud Circuit Breaker starter时,将自动为你创建实现此API的bean。下面的例子展示了如何使用这个API的一个简单例子:

<dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId></dependency>
或者(反应式)
<dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-circuitbreaker-reactor-resilience4j</artifactId></dependency>

简单API应用

@Servicepublic 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和一个FunctionSupplier是你要包装在断路器中的代码。Function是在断路器跳闸时运行的后备功能。Function被传递导致触发回退的Throwable。如果你不想提供一个回退,你可以选择排除它。

反应式应用

如果Project Reactor位于类路径上,你还可以为响应式代码使用ReactiveCircuitBreakerFactory。下面的例子展示了如何做到这一点:

@Servicepublic static class DemoControllerService {    private ReactiveCircuitBreakerFactory cbFactory;    private WebClient webClient;

public DemoControllerService(WebClient webClient, ReactiveCircuitBreakerFactory cbFactory) { this.webClient = webClient; this.cbFactory = cbFactory; }
public Mono<Users> 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方法将一个MonoFlux包在一个断路器中。你可以选择配置一个回退函数,该函数将在断路器被触发并传递导致故障的Throwable时被调用。

配置

你可以通过创建Customizer类型的bean来配置断路器工厂。Customizer接口有一个方法(称为customize)

// 对断路器工厂进行自定义@Componentpublic class PackCircuitBreakerCustomizer implements Customizer<Resilience4JCircuitBreakerFactory> {
@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)

完毕!


【声明】内容源于网络
0
0
Spring全家桶实战案例
Java全栈开发,前端Vue2/3全家桶;Spring, SpringBoot 2/3, Spring Cloud各种实战案例及源码解读
内容 832
粉丝 0
Spring全家桶实战案例 Java全栈开发,前端Vue2/3全家桶;Spring, SpringBoot 2/3, Spring Cloud各种实战案例及源码解读
总阅读38
粉丝0
内容832