当前位置：首页 > 科技 > 软件

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

来源：责编：时间：2023-11-06 08:52:52 180观看

导读环境：SpringBoot2.4.12 + Spring Cloud Hoxton.SR12简介Spring Cloud 断路器提供了不同断路器实现之间的抽象。它提供了在应用程序中使用的一致API，让开发人员选择最适合应用程序需求的断路器实现。Spring Cloud支持以

环境：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和一个Function。Supplier是你要包装在断路器中的代码。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方法将一个Mono或Flux包在一个断路器中。你可以选择配置一个回退函数，该函数将在断路器被触发并传递导致故障的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)

完毕！！！

本文链接：http://www.28at.com/showinfo-26-17158-0.html断路器在项目中的重要性：保护远程接口调用的稳定运行

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：聊聊Spring 微服务和多租户

下一篇： AIDL在Android应用程序中的重要作用

标签：

热门焦点

Redmi Pad评测：红米充满野心的一次尝试

从Note系列到K系列，从蓝牙耳机到笔记本电脑，红米不知不觉之间也已经形成了自己颇有竞争力的产品体系，在中端和次旗舰市场上甚至要比小米新机的表现来得更好，正所谓“大丈夫生居
vivo TWS Air开箱体验：真轻臻好听

在vivo S15系列新机的发布会上，vivo的最新款真无线蓝牙耳机vivo TWS Air也一同发布，本次就这款耳机新品给大家带来一个简单的分享。外包装盒上，vivo TWS Air保持了vivo自家产
分布式系统中的CAP理论，面试必问，你理解了嘛？

对于刚刚接触分布式系统的小伙伴们来说，一提起分布式系统，就感觉高大上，深不可测。而且看了很多书和视频还是一脸懵逼。这篇文章主要使用大白话的方式，带你理解一下分布式系统
.NET 程序的 GDI 句柄泄露的再反思

一、背景1. 讲故事上个月我写过一篇如何洞察 C# 程序的 GDI 句柄泄露文章，当时用的是 GDIView + WinDbg 把问题搞定，前者用来定位泄露资源，后者用来定位泄露代码，后面有朋友反
苹果、三星、惠普等暂停向印度出口笔记本和平板电脑

集微网消息，据彭博社报道，在8月3日印度突然禁止在没有许可证的情况下向印度进口电脑/平板及显示器等产品后，苹果、三星电子和惠普等大公司暂停向印度
到手价3099元起！iQOO Neo8 Pro今日首销：安卓性能最强旗舰

5月23日，iQOO如期举行了新品发布会，全新的iQOO Neo8系列也正式与大家见面，包含iQOO Neo8和iQOO Neo8 Pro两个版本，其中标准版搭载高通骁龙8+，而Pro版更
iQOO Neo8 Pro真机谍照曝光：天玑9200+和V1+旗舰双芯加持

去年10月，iQOO推出了iQOO Neo7系列机型，不仅搭载了天玑9000+，而且是同价位唯一一款天玑9000+直屏旗舰，一经上市便受到了用户的广泛关注。在时隔半年后，
荣耀Magicbook V 14 2021曙光蓝版本正式开售，拥有触摸屏

荣耀 Magicbook V 14 2021 曙光蓝版本正式开售，搭载 i7-11390H 处理器与 MX450 显卡，配备 16GB 内存与 512GB SSD，重 1.48kg，厚 14.5mm，具有 1.5mm 键盘键程、
外交部：美方应停止在网络安全问题上不负责任地指责他国

　中国外交部今天（16日）举行例行记者会。会上，有记者问，美国情报官员称，他们正在阻拦来自中国以及其他国家的黑客获取相关科研成果。中方对此有何评论？对此