本文主要是介绍resilience4j的circuitbeaker，bulkheader,ratelimiter，retry的使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
resilience4j是提供服务熔断，降级，限流，重试等能力的微服务组件。在hystrix不再维护之后，目前作为前者的替代品。也是目前官方所主推的组件。其相对于hystrix更轻量级，没有复杂的依赖。其提供的能力比hystrix更强。其函数式风格的api能写出很简洁的代码。也有和spring-boot整合，能通过简单的注解和配置来集成其能力。其主要组件主要为**circuitbeaker（断路器），bulkheader（挡板）,ratelimiter（限流器），retry（重试）**各个组件状态的变更都内置了事件接口。可以针对其事件做一个处理。
1.circuitbeaker(断路器)
断路器：在微服务技术中扮演则重要的角色，其主要作用是检测服务的异常次数，在达到阈值后会打开断路器，进行服务降级。避免拖垮整个服务。再后续一段时间后，又会放出一部分流量，看调用是否正常再决定关闭断路器。状态的转换图如下（图片来自官网）
关闭状态，打开状态，半开状态，3者的状态根据调用统计的结果相互转换
。
调用次数结果的存贮基于滑动窗口算法。
circuitbreaker提供了2种滑动窗口算法，一种基于有限窗口的总次数，（例如窗口的大小为10，就统计最近10次的调用结果来进行状态的转换），另一种基于时间的窗口算法。例如窗口是10，则可把最近10秒看做10个桶子，每个桶子保留当前那秒对应的所有调用结果，根据所有桶内的调用结果来进行状态的转换
1.1 circuitBeaker api的使用
CircuitBeakerRegistry：单个registry实例，可配置CircuitBreakerConfig，用户可根据自己想选择的Config类来生成对应的circuitBreaker实例。
主要属性如下
| 配置属性 | 默认值 | 描述 |
|---|---|---|
| failureRateThreshold | 50 | 失败率，调用失败达到该阈值，断路器会被打开，默认为50% |
| permittedNumberOfCalls | ||
| InHalfOpenState | 10 | 半开状态下，能提供的凭证（即能通过的调用） |
| slidingWindowType | COUNT_BASED | 滑动窗口类型，默认为累计计数 |
| slidingWindowSize | 100 | 滑动窗口大小 |
| minimumNumberOfCalls | 100 | 每个滑块周期内，至少要满足多少调用次数，否则即使达到了错误率，也不会进行状态的变更 |
| recordExceptions | empty | 该被纳入错误率计算的异常，默认为空 |
| ignoreExceptions | empty | 不该被纳入错误率计算的异常，默认为空 |
| recordFailurePredicate | throwable -> true | 异常预测类，默认异常都为true,即都该被纳入错误率 |
| ignoreExceptionPredicate | throwable -> false | 异常忽略预测类，默认异常都为false,即都不该纳入错误率 |
其余详细配置，其移步官方文档
https://resilience4j.readme.io/docs/circuitbreaker
示例代码如下
如果是maven项目，需引入相关依赖，由于我使用的是spring-boot所以直接引入spring-boot的resilience4j
<dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot2</artifactId><version>1.7.1</version></dependency>
原生api的使用
package com.ly;import io.github.resilience4j.bulkhead.Bulkhead;
import io.github.resilience4j.bulkhead.BulkheadConfig;
import io.github.resilience4j.bulkhead.ThreadPoolBulkhead;
import io.github.resilience4j.bulkhead.ThreadPoolBulkheadConfig;
import io.github.resilience4j.circuitbreaker.CircuitBreaker;
import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig;
import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry;
import io.github.resilience4j.ratelimiter.RateLimiter;
import io.github.resilience4j.ratelimiter.RateLimiterConfig;
import io.github.resilience4j.retry.Retry;
import io.github.resilience4j.retry.RetryConfig;
import io.vavr.control.Try;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;import java.time.Duration;
import java.util这篇关于resilience4j的circuitbeaker，bulkheader,ratelimiter，retry的使用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
