spring cloud Resilience4j - 熔断器 CircuitBreaker

在微服务架构中，一般我们的独立服务是比较多的，每个独立服务之间划分责任边界，并通过约定协议接口来进行通信。当我们的调用链路复杂依赖多时，很可能会发生雪崩效应。

假设有这么一个场景，有A, B, C, D四个独立服务，A会依赖B，C，D；当D发生负载过高或网络异常等导致响应过慢或超时时，很可能A会因此堆积过多的等待链接，从而导致A的状态也转为异常，后面依赖到A的其他服务跟着发生链式反应，这将会导致大面积的服务不可用，即使本来是一些没有依赖到B，C，D的服务。

状态说明

熔断器有如下状态：

• CLOSED： 熔断器关闭，表示接口状态正常。
• OPEN：熔断器打开，表示接口状态异常，直接抛出CallNotPermittedException。如果有failback则调用failback函数。
• HALF_OPEN：半开状态，允许指定数量的请求通过，以查看后端服务是否正常。超过指定数量的请求，抛出CallNotPermittedException。
• DISABLED：停用熔断器，所有请求允许通过。
• FORCED_OPEN：强制开启熔断器，所有请求不允许通过。

状态机：

滑动窗口

Resilience4j 支持两种滑动窗口算法：

• 基于数量的滑动窗口：
  统计指定数量的请求数，请求先进先出，计算失败比例。查询失败比例的时间复杂度为O(1)，与窗口大小无关；空间复杂度为O(n)
• 基于时间的滑动窗口：
  窗口包含N个桶，N为时间秒数。分别计算每个桶的失败比例，然后计算一个总数。桶也是先进先出。查询失败比例的时间复杂度为O(1)，与窗口大小无关；空间复杂度为O(n)

参数说明

实例

配置文件

application.properties

resilience4j.circuitbreaker:instances:backendA:registerHealthIndicator: trueslidingWindowSize: 100backendB:registerHealthIndicator: trueslidingWindowSize: 10permittedNumberOfCallsInHalfOpenState: 3slidingWindowType: TIME_BASEDminimumNumberOfCalls: 20waitDurationInOpenState: 50sfailureRateThreshold: 50eventConsumerBufferSize: 10recordFailurePredicate: io.github.robwin.exception.RecordFailurePredicate

规则取名为-order

使用注解方式实现熔断

    @GetMapping("/getCoffee1")@io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker(name = "order"，fallbackMethod = "fallback")public Coffee getCoffee1() {Coffee list = coffeeService.getById(1l);log.info("Read coffee: {} coffee", list);return list;}private Coffee fallback(IllegalArgumentException e){return new Coffee();}private Coffee fallback(RuntimeException e){return new Coffee();}

使用代码注册的方式实现

  private CircuitBreaker circuitBreaker;public CustomerController(CircuitBreakerRegistry registry) {circuitBreaker = registry.circuitBreaker("order");}@GetMapping("/getCoffee2")public List<Coffee> getCoffee2() {return Try.ofSupplier(CircuitBreaker.decorateSupplier(circuitBreaker,() -> coffeeService.getAll())).recover(CircuitBreakerOpenException.class, Collections.emptyList()).get();}

响应式：

@CircuitBreaker(name = BACKEND, fallbackMethod = "fallback")
@RateLimiter(name = BACKEND)
@Bulkhead(name = BACKEND)
@Retry(name = BACKEND, fallbackMethod = "fallback")
@TimeLimiter(name = BACKEND)
public Mono<String> method(String param1) {return Mono.error(new NumberFormatException());
}private Mono<String> fallback(String param1, IllegalArgumentException e) {return Mono.just("test");
}private Mono<String> fallback(String param1, RuntimeException e) {return Mono.just("test");
}

更多

spring cloud resilience4j-retry 重试
spring cloud resilience4j - Bulkhead 线程隔离 并发控制
spring cloud Resilience4j - 熔断器 CircuitBreaker
spring cloud resilience4j - RateLimiter 流控
参考：
https://resilience4j.readme.io/docs/getting-started-3