Hystrix官方已停止维护，官方推荐使用Resilience4j来替代Hystrix实现服务治理，今天我们看看如何使用Resilience4j。

介绍

1、一款受 Hystrix 启发的轻量量级且易于使用的容错库
2、针对 Java 8 与函数式编程设计
3、github地址：https://github.com/resilience4j/resilience4j
4、核心组件：

如何基于Resilience4j实现断路器断路器

1、Resilience4j的circuitbreaker组件实现了断路器功能，他是基于内存的断路器，采用
ConcurrentHashMap来实现的。

2、断路器的功能主要是处理熔断，当客户端调用服务端出现问题时进行拦截，直接返回，不再发送请求给服务端，减少下游服务的冲击。

实验环境

1、基于Eureka的服务注册和发现
2、提供服务的waiter-service
3、客户端调用customer-service

关键代码1、启动waiter-service和customer-service服务，分别注册到Eureka,这里不再介绍，可以参考之前的博客。2、waiter-service作为服务提供方，不涉及到配置代码3、关键代码在客户端customer-service

3.1、断路器的配置：application.properties
规则取名为-order

resilience4j.circuitbreaker.backends.order.failure-rate-threshold=50resilience4j.circuitbreaker.backends.order.wait-duration-in-open-state=5000resilience4j.circuitbreaker.backends.order.ring-buffer-size-in-closed-state=5resilience4j.circuitbreaker.backends.order.ring-buffer-size-in-half-open-state=3resilience4j.circuitbreaker.backends.order.event-consumer-buffer-size=10

3.2、使用注解的方式实现断路器

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

3.3、使用注册方式，实现断路器，短路之后默认返回空的list

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(); }

3.4、关闭waiter-service，模拟服务宕机，展示效果

连续请求3次，服务调用失败

失败超过50%，第4次触发短路器打开：

等待5秒钟，断路器尝试重连：