Spring Cloud熔斷器Hystrix

在微服務(wù)架構(gòu)中,根據(jù)業(yè)務(wù)來拆分成一個個的服務(wù),服務(wù)與服務(wù)之間可以相互調(diào)用(RPC),在Spring Cloud可以用RestTemplate+Ribbon和Feign來調(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)

Netflix開源了Hystrix組件,實現(xiàn)了斷路器模式,SpringCloud對這一組件進行了整合。 在微服務(wù)架構(gòu)中,一個請求需要調(diào)用多個服務(wù)是非常常見的

較底層的服務(wù)如果出現(xiàn)故障,會導(dǎo)致連鎖故障。當(dāng)對特定的服務(wù)的調(diào)用的不可用達(dá)到一個閥值(Hystric 是5秒20次) 斷路器將會被打開。

斷路打開后,可用避免連鎖故障,fallback方法可以直接返回一個固定值。

二、準(zhǔn)備工作

這篇文章基于上一篇文章的工程,首先啟動上一篇文章的工程,啟動eureka-server 工程;啟動service-hi工程,它的端口為8762。

三、在ribbon使用斷路器

改造serice-ribbon 工程的代碼,首先在pox.xml文件中加入spring-cloud-starter-hystrix的起步依賴:

org.springframework.cloud

spring-cloud-starter-hystrix

在程序的啟動類ServiceRibbonApplication 加@EnableHystrix注解開啟Hystrix:

@SpringBootApplication

@EnableDiscoveryClient

@EnableHystrix

public class ServiceRibbonApplication {

public static void main(String[] args) {

SpringApplication.run(ServiceRibbonApplication.class, args);

}

@Bean

@LoadBalanced

RestTemplate restTemplate() {

return new RestTemplate();

}

}

改造HelloService類,在hiService方法上加上@HystrixCommand注解。該注解對該方法創(chuàng)建了熔斷器的功能,并指定了fallbackMethod熔斷方法,熔斷方法直接返回了一個字符串,字符串為”hi,”+name+”,sorry,error!”,代碼如下:

@Service

public class HelloService {

@Autowired

RestTemplate restTemplate;

@HystrixCommand(fallbackMethod = "hiError")

public String hiService(String name) {

return restTemplate.getForObject("http://SERVICE-HI/hi?name="+name,String.class);

}

public String hiError(String name) {

return "hi,"+name+",sorry,error!";

}

}

啟動:service-ribbon 工程,瀏覽器顯示:

hi forezp,i am from port:8762

此時關(guān)閉 service-hi 工程,,瀏覽器會顯示:

hi ,forezp,orry,error!

這就說明當(dāng) service-hi 工程不可用的時候,service-ribbon調(diào)用 service-hi的API接口時,會執(zhí)行快速失敗,直接返回一組字符串,而不是等待響應(yīng)超時,這很好的控制了容器的線程阻塞。

四、Feign中使用斷路器

Feign是自帶斷路器的,在D版本的Spring Cloud中,它沒有默認(rèn)打開。需要在配置文件中配置打開它,在配置文件加以下代碼:

feign.hystrix.enabled=true

基于service-feign工程進行改造,只需要在FeignClient的SchedualServiceHi接口的注解中加上fallback的指定類就行了:

@FeignClient(value = "service-hi",fallback = SchedualServiceHiHystric.class)

public interface SchedualServiceHi {

@RequestMapping(value = "/hi",method = RequestMethod.GET)

String sayHiFromClientOne(@RequestParam(value = "name") String name);

}

SchedualServiceHiHystric需要實現(xiàn)SchedualServiceHi 接口,并注入到Ioc容器中,代碼如下:

@Component

public class SchedualServiceHiHystric implements SchedualServiceHi {

@Override

public String sayHiFromClientOne(String name) {

return "sorry "+name;

}

}

啟動四servcie-feign工程,注意此時service-hi工程沒有啟動,網(wǎng)頁顯示:

sorry forezp

打開service-hi工程,再次訪問,瀏覽器顯示:

hi forezp,i am from port:8762

這證明斷路器起到作用了。

五、Hystrix Dashboard (斷路器:Hystrix 儀表盤)

基于service-ribbon 改造,F(xiàn)eign的改造和這一樣。

首選在pom.xml引入spring-cloud-starter-hystrix-dashboard的起步依賴:

org.springframework.boot

spring-boot-starter-actuator

org.springframework.cloud

spring-cloud-starter-hystrix-dashboard

在主程序啟動類中加入@EnableHystrixDashboard注解,開啟hystrixDashboard:

@SpringBootApplication

@EnableDiscoveryClient

@EnableHystrix

@EnableHystrixDashboard

public class ServiceRibbonApplication {

..//代碼省略

}

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn),斷路器,智...
    卡卡羅2017閱讀 136,554評論 19 139
  • 微服務(wù)架構(gòu)中,微服務(wù)之間相互調(diào)用,springcloud可以用feign方式和RestTemplate+ribbo...
    Java黎先生閱讀 712評論 0 0
  • Spring Cloud 代碼地址:https://github.com/jedyang/springCloud ...
    運維開發(fā)筆記閱讀 820評論 0 5
  • 微服務(wù)架構(gòu)模式的核心在于如何識別服務(wù)的邊界,設(shè)計出合理的微服務(wù)。但如果要將微服務(wù)架構(gòu)運用到生產(chǎn)項目上,并且能夠發(fā)揮...
    java菜閱讀 3,052評論 0 6
  • 說明 在微服務(wù)的體系下,服務(wù)之間是與依賴關(guān)系的!服務(wù)的調(diào)用中也存在著各種可能的問題,如果一個服務(wù)處理緩慢,可能會導(dǎo)...
    hutou閱讀 4,127評論 0 3

友情鏈接更多精彩內(nèi)容