服務治理-Resilience4j（熔斷）

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=50
resilience4j.circuitbreaker.backends.order.wait-duration-in-open-state=5000
resilience4j.circuitbreaker.backends.order.ring-buffer-size-in-closed-state=5
resilience4j.circuitbreaker.backends.order.ring-buffer-size-in-half-open-state=3
resilience4j.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秒鐘，斷路器嘗試重連：