在微服務(wù)架構(gòu)中，根據(jù)業(yè)務(wù)來拆分成一個個的服務(wù)，在SpringCloud中用RestTemplate+Ribbon和Feign來實現(xiàn)互相調(diào)用。為了保證其高可用，單個服務(wù)通常會集群部署。

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

服務(wù)與服務(wù)之間的依賴性，故障會傳播，會對整個微服務(wù)系統(tǒng)造成災(zāi)難性的嚴(yán)重后果，這就是服務(wù)故障的“雪崩”效應(yīng)。

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

一、什么是斷路器

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。 -------來自官網(wǎng)

當(dāng)?shù)讓臃?wù)出現(xiàn)故障時會導(dǎo)致連鎖故障。當(dāng)對特定的服務(wù)的調(diào)用的不可用達到一個閥值（Hystric 是5秒20次） 斷路器將會被打開。斷路打開后，可用避免連鎖故障，fallback方法可以直接返回一個固定值。

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

Feign本身就集成了Hystrix，只是默認(rèn)為關(guān)閉狀態(tài)，我們需要在配置文件中將其打開

feign:hystrix:enabled: true 復(fù)制代碼

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

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 #配置規(guī)則 隨機 #com.netflix.loadbalancer.RoundRobinRule #配置規(guī)則 輪詢 #com.netflix.loadbalancer.RetryRule #配置規(guī)則 重試 #com.netflix.loadbalancer.WeightedResponseTimeRule #配置規(guī)則 響應(yīng)時間權(quán)重 #com.netflix.loadbalancer.BestAvailableRule #配置規(guī)則 最空閑連接策略 復(fù)制代碼

項目結(jié)構(gòu)如下：

新建feign斷路器接口SchedualClientNameWithFallbackFactory和斷路器的實現(xiàn)類HystrixClientFallbackFactory

package com.hewl.hystrix;import com.hewl.feign.SchedualCilentName;public interface SchedualClientNameWithFallbackFactory extends SchedualCilentName {}復(fù)制代碼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();}};}}復(fù)制代碼

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);} 復(fù)制代碼

下面啟動項目測試

啟動eureka-server服務(wù)

啟動eureka-client服務(wù)

啟動feign服務(wù)

訪問http://localhost:8811/test

熔斷成功！！！

轉(zhuǎn)載于:https://juejin.im/post/5d01f057f265da1bd04edac8

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。