為什么需要服務熔斷
在微服務架構中,根據(jù)業(yè)務來拆分成一個個的服務钞速,服務與服務之間可以相互調(diào)用。為了保證其高可用嫡秕,單個服務通常會集群部署渴语。由于網(wǎng)絡原因或者自身的原因,服務并不能保證100%可用淘菩,如果單個服務出現(xiàn)問題遵班,調(diào)用這個服務就會出現(xiàn)線程阻塞,此時若有大量的請求涌入潮改,Servlet容器的線程資源會被消耗完畢狭郑,導致服務癱瘓。服務與服務之間的依賴性汇在,故障會傳播翰萨,會對整個微服務系統(tǒng)造成災難性的嚴重后果,這就是服務故障的“雪崩”效應糕殉。為了解決這個問題亩鬼,出現(xiàn)了熔斷器模型。
可以通過下圖簡單理解:
較底層的服務如果出現(xiàn)故障阿蝶,會導致連鎖故障雳锋。當對特定的服務的調(diào)用的不可用達到一個閥值(Hystric 是5秒20次) 斷路器將會被打開。斷路打開后羡洁,可用避免連鎖故障玷过,fallback方法可以直接返回一個固定值。
- 引入依賴:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
- 配置文件(參考Ribbon篇配置)
Feign是自帶斷路器的,它沒有默認打開辛蚊。需要在配置文件中配置打開它粤蝎,在配置文件加以下代碼:
feign.hystrix.enabled=true
- 核心代碼:
將上一篇中的service-feign工程進行改造,在FeignClient的SchedualServiceHello接口的注解中加上fallback的指定類就行了:
@FeignClient(value = "service-1", fallback = SchedualServiceHelloHystric.class)
public interface SchedualServiceHello {
@RequestMapping(value = "/hello",method = RequestMethod.GET)
String sayHelloFromClientOne(@RequestParam(value = "name") String name);
}
SchedualServiceHelloHystric需要實現(xiàn)SchedualServiceHello 接口袋马,并注入到Ioc容器中初澎,代碼如下:
@Component
public class SchedualServiceHelloHystric implements SchedualServiceHello {
@Override
public String sayHelloFromClientOne(String name) {
return "error" + name;
}
}
此時不啟動service-1服務,只啟動servcie-feign服務虑凛,訪問http://localhost:8765/hello?name=tom
碑宴,結果顯示:
error tom
啟動service-1服務,再次訪問鏈接卧檐,結果顯示:
hello tom