SpringCloud学习（五）----- Gatewayw网关完善（Resilience4j断路器）
SpringCloud版本：2021.0.1 SpringBoot版本：2.6.3
系列文章
SpringCloud学习（一）----- Eureka搭建
SpringCloud学习（二）----- SpringBoot Admin搭建（与Eureka整合）
SpringCloud学习（三）----- Gatewayw网关搭建
SpringCloud学习（四）----- Gatewayw网关完善（限流）
SpringCloud学习（五）----- Gatewayw网关完善（Resilience4j断路器）
参考文章：
断路器：Resilience4j配置及应用(gateway应用)
一开始我所要集成的是Hystrix，但看了很多文章都没法成功，后面没办法了就去SpringCloud的官网看了一下，发现因为我用的是最新版的SpringCloud,而在最新版里，默认的那个Hystrix的拦截器没有了，所以是没用的，后面我就采用了Resilience4j来进行服务的一个熔断的功能。
目录
1、为什么要使用断路器？
2、什么是熔断机制？
3、断路器的机制
4、Resilience4j的使用
4.1 引入依赖jar包
4.2 在application.yml里增加Resilience4j的配置
4.3 加载自定义配置
4.4 修改application.yml配置
1、为什么要使用断路器？
在微服务架构中，我们将业务拆分成一个个的服务，服务与服务之间可以相互调用（RPC）。那么，为了保证其高可用，单个服务又必须进行集群部署。但由于网络原因或者自身的原因，服务并不能保证服务的100%可用，如果单个服务出现问题，调用这个服务就会出现网络延迟，此时若有大量的网络涌入，会形成任务累计，导致服务瘫痪，甚至导致服务“雪崩”。
而预防或减少服务的雪崩，我们可以有几个应对的策略：
1.流量控制
2.改进缓存模式
3.服务自动扩容
4.服务调用者降级服务
而这一次，所要讲的是第4种的方法，即服务调用者降级服务，也可以说是熔断机制。
2、什么是熔断机制？
熔断机制，就是下游服务出现问题后，为保证整个系统正常运行下去，而提供一种降级服务的机制，通过返回缓存数据或者既定数据，避免出现系统整体雪崩效应。在SpringCloud中，该功能可通过配置的方式加入到项目中。
3、断路器的机制
断路器很好理解, 当请求后端服务失败数量超过一定比例(比如50%), 断路器会切换到开路状态(Open). 这时所有请求会直接失败而不会发送到后端服务. 断路器保持在开路状态一段时间后(比如5秒), 自动切换到半开路状态(HALF-OPEN). 这时会判断下一次请求的返回情况, 如果请求成功, 断路器切回闭路状态(CLOSED), 否则重新切换到开路状态(OPEN).。断路器就像我们家庭电路中的保险丝, 一旦后端服务不可用, 断路器会直接切断请求链, 避免发送大量无效请求影响系统吞吐量, 并且断路器有自我检测并恢复的能力。
4、Resilience4j的使用
4.1 引入依赖jar包
org.springframework.cloud spring-cloud-starter-circuitbreaker-reactor-resilience4j io.github.resilience4j resilience4j-spring-boot2 1.1.0 4.2 在application.yml里增加Resilience4j的配置
resilience4j.circuitbreaker: configs: #通用配置 default: # 断路器系统默认配置 #失败率，错误率达到或高于该值则进入open状态 failureRateThreshold: 50 #慢调用阀值，请求执行的时间大于该值时会标记为慢调用 slowCallDurationThreshold: 60s #慢调用熔断阀值，当慢调用率达到或高于该值时，进入open状态 slowCallRateThreshold: 100 #状态滚动收集器大小，close状态时收集多少请求状态，用于计算失败率。 slidingWindowSize: 100 #状态收集器类型 #COUNT_BASED：根据数量计算，slidingWindowSize为次数 #TIME_BASED：根据时间计算，slidingWindowSize为秒数 slidingWindowType: COUNT_BASED #计算错误率的最小请求数，不足最小调用次数不会触发任何变化。 minimumNumberOfCalls: 10 #是否自动进入halfOpen状态，默认false-一定时间后进入halfopen，ture-需要通过接口执行。 automaticTransitionFromOpenToHalfOpenEnabled: false #进入halfOpen状态时，可以被调用次数，就算这些请求的失败率，低于设置的失败率变为close状态，否则变为open。 permittedNumberOfCallsInHalfOpenState: 10 #open状态变为half状态需要等待的时间，即熔断多久后开始尝试访问被熔断的服务。 waitDurationInOpenState: 60s #事件缓冲区大小？？ eventConsumerBufferSize: 10 #被计为失败的异常集合，默认情况下所有异常都为失败。 recordExceptions: - java.lang.Exception #不会被计为失败的异常集合，优先级高于recordExceptions。 ignoreExceptions: - java.lang.IllegalStateException instances: #熔断器类型 aCustomizer: #使用默认配置 baseConfig: default cacheCustomizer: #自定义配置 failureRateThreshold: 104.3 加载自定义配置
@SpringBootApplicationpublic class GatewayApplication { public static void main(String[] args){ SpringApplication.run(GatewayApplication.class, args); } / * 初始化断路器，读取Resilience4J的yaml配置 * @param circuitBreakerRegistry * @return */ @Bean public ReactiveResilience4JCircuitBreakerFactory reactiveResilience4JCircuitBreakerFactory( CircuitBreakerRegistry circuitBreakerRegistry) { ReactiveResilience4JCircuitBreakerFactory factory = new ReactiveResilience4JCircuitBreakerFactory(); //自定义断路器配置// CircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig.custom().slidingWindowSize(100).build(); //设置断路器默认配置 //不修改默认值可以忽略 factory.configureDefault(id -> new Resilience4JConfigBuilder(id) //默认超时规则,默认1s,不使用断路器超时规则可以设置大一点 .timeLimiterConfig(TimeLimiterConfig.custom().timeoutDuration(Duration.ofMillis(60000)).build()) //默认断路器规则// .circuitBreakerConfig(circuitBreakerConfig).build()) .build()); //添加自定义拦截器 factory.configureCircuitBreakerRegistry(circuitBreakerRegistry); return factory; }}4.4 修改application.yml配置
server: port: 80spring: application: name: test-gateway security: user: name: test password: 123456 cloud: gateway: globalcors: cors-configurations: '[/]': # 匹配所有请求 allowedOrigins: "*" #跨域处理 允许所有的域 allowedMethods: # 支持的方法 - GET - POST - PUT - DELETE discovery: locator: enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由 routes: #路径匹配 - id: find uri: https://blog.csdn.net # 测试 predicates: - Path=/csdn/ filters: - StripPrefix=1 #去掉Path前缀,参数为1代表去掉/csdn - RL #注意：RLGatewayFilterFactory，只需要写RL - name: CircuitBreaker #使用resilience4j断路器 args:name: cacheCustomizer #自定义断路器配置fallbackUri: forward:/cache/timestemp #异常跳转eureka: instance: leaseRenewalIntervalInSeconds: 10 health-check-url-path: /actuator/health hostname: 127.0.0.1 client: registryFetchIntervalSeconds: 5 service-url: defaultZone: http://${spring.security.user.name}:${spring.security.user.password}@${eureka.instance.hostname}:8001/eureka/management: endpoints: web: exposure: include: "*" endpoint: health: show-details: ALWAYS
