服務治理-Resilience4j(熔斷)

Hystrix官方已中止維護,官方推薦使用Resilience4j來替代Hystrix實現服務治理,今天咱們看看如何使用Resilience4j。git

介紹

一、一款受 Hystrix 啓發的輕量量級且易於使用的容錯庫
二、針對 Java 8 與函數式編程設計
三、github地址:https://github.com/resilience4j/resilience4j
四、核心組件:
服務治理-Resilience4j(熔斷)github

如何基於Resilience4j實現斷路器

斷路器

一、Resilience4j的circuitbreaker組件實現了斷路器功能,他是基於內存的斷路器,採用
ConcurrentHashMap來實現的。編程

二、斷路器的功能主要是處理熔斷,當客戶端調用服務端出現問題時進行攔截,直接返回,再也不發送請求給服務端,減小下游服務的衝擊。app

實驗環境

一、基於Eureka的服務註冊和發現
二、提供服務的waiter-service
三、客戶端調用customer-serviceide

關鍵代碼

一、啓動waiter-service和customer-service服務,分別註冊到Eureka,這裏再也不介紹,能夠參考以前的博客。

二、waiter-service做爲服務提供方,不涉及到配置代碼

三、關鍵代碼在客戶端customer-service

3.一、斷路器的配置: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.二、使用註解的方式實現斷路器函數

@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.三、使用註冊方式,實現斷路器,短路以後默認返回空的listui

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.四、關閉waiter-service,模擬服務宕機,展現效果設計

連續請求3次,服務調用失敗
服務治理-Resilience4j(熔斷)code

失敗超過50%,第4次觸發短路器打開:
服務治理-Resilience4j(熔斷)

等待5秒鐘,斷路器嘗試重連:
服務治理-Resilience4j(熔斷)

相關文章
相關標籤/搜索