在微服務架構中，根據業務來拆分成一個個的服務，在SpringCloud中用RestTemplate+Ribbon和Feign來實現互相調用。為了保證其高可用，單個服務通常會集群部署。

由于網絡原因或者自身的原因，服務并不能保證100%可用，如果單個服務出現問題，調用這個服務就會出現線程阻塞，此時若有大量的請求涌入，Servlet容器的線程資源會被消耗完畢，導致服務癱瘓。

服務與服務之間的依賴性，故障會傳播，會對整個微服務系統造成災難性的嚴重后果，這就是服務故障的“雪崩”效應。

為了解決這個問題，業界提出了斷路器模型。

一、什么是斷路器

Netflix has created a library called Hystrix that implements the circuit breaker pattern. In a microservice architecture it is common to have multiple layers of service calls。 -------來自官網

當底層服務出現故障時會導致連鎖故障。當對特定的服務的調用的不可用達到一個閥值（Hystric 是5秒20次） 斷路器將會被打開。斷路打開后，可用避免連鎖故障，fallback方法可以直接返回一個固定值。

二、這里我們直接說Feign集成Hystrix

Feign本身就集成了Hystrix，只是默認為關閉狀態，我們需要在配置文件中將其打開

feign:hystrix:enabled: true 復制代碼

下面我們來看看代碼如何寫，其實很簡單，使用上一篇文章中的cloud-demo-feign項目，application.yml內容如下：

server:port: 8811 # 你的端口 spring:application:name: feign eureka:client:service-url:defaultZone: http://admin:admin@server1:8761/eureka/,http://admin:admin@server2:8762/eureka/ feign:hystrix:enabled: true service-eureka-client:ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #com.netflix.loadbalancer.RandomRule #配置規則 隨機 #com.netflix.loadbalancer.RoundRobinRule #配置規則 輪詢 #com.netflix.loadbalancer.RetryRule #配置規則 重試 #com.netflix.loadbalancer.WeightedResponseTimeRule #配置規則 響應時間權重 #com.netflix.loadbalancer.BestAvailableRule #配置規則 最空閑連接策略 復制代碼

項目結構如下：

新建feign斷路器接口SchedualClientNameWithFallbackFactory和斷路器的實現類HystrixClientFallbackFactory

package com.hewl.hystrix;import com.hewl.feign.SchedualCilentName;public interface SchedualClientNameWithFallbackFactory extends SchedualCilentName {}復制代碼package com.hewl.hystrix;import java.util.HashMap; import java.util.Map;import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component;import com.hewl.feign.SchedualCilentName;import feign.hystrix.FallbackFactory;@Component public class HystrixClientFallbackFactory implements FallbackFactory<SchedualCilentName> {private static final Logger log = LoggerFactory.getLogger(HystrixClientFallbackFactory.class);@Overridepublic SchedualCilentName create(Throwable cause) {// TODO Auto-generated method stubreturn new SchedualClientNameWithFallbackFactory() {@Overridepublic String testFromClientOne(String name) {log.error("fallback ,the result is : " + cause);// TODO Auto-generated method stubMap<String, Object> map = new HashMap<String, Object>();map.put("ID", -1L);map.put("NAME","");return map.toString();}};}}復制代碼

SchedualCilentName類做如下修改，feignclient注解添加fallbackfactory鍵值對

package com.hewl.feign;import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestParam;import com.hewl.hystrix.HystrixClientFallbackFactory;@FeignClient(value="service-eureka-client",fallbackFactory = HystrixClientFallbackFactory.class) public interface SchedualCilentName {@GetMapping(value = "/test")public String testFromClientOne(@RequestParam("name") String name);} 復制代碼

下面啟動項目測試

啟動eureka-server服務

啟動eureka-client服務

啟動feign服務

訪問http://localhost:8811/test

熔斷成功！！！

轉載于:https://juejin.im/post/5d01f057f265da1bd04edac8

總結

以上是生活随笔為你收集整理的Eclipse(STS) 初次搭建Spring Cloud项目之断路器Hystrix（五）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。