Hystrix官方已中止維護,官方推薦使用Resilience4j來替代Hystrix實現服務治理,今天咱們看看如何使用Resilience4j。git
一、一款受 Hystrix 啓發的輕量量級且易於使用的容錯庫
二、針對 Java 8 與函數式編程設計
三、github地址:https://github.com/resilience4j/resilience4j
四、核心組件:github
一、Resilience4j的circuitbreaker組件實現了斷路器功能,他是基於內存的斷路器,採用
ConcurrentHashMap來實現的。編程
二、斷路器的功能主要是處理熔斷,當客戶端調用服務端出現問題時進行攔截,直接返回,再也不發送請求給服務端,減小下游服務的衝擊。app
一、基於Eureka的服務註冊和發現
二、提供服務的waiter-service
三、客戶端調用customer-serviceide
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次,服務調用失敗code
失敗超過50%,第4次觸發短路器打開:
等待5秒鐘,斷路器嘗試重連: