SpringCloud系列：Spring Cloud第四章：熔斷器Hystrix

在微服務(wù)架構(gòu)中，根據(jù)業(yè)務(wù)來(lái)拆分成一個(gè)個(gè)的服務(wù)，服務(wù)與服務(wù)之間可以相互調(diào)用（RPC），在Spring Cloud可以用RestTemplate+Ribbon和Feign來(lái)調(diào)用。為了保證其高可用，單個(gè)服務(wù)通常會(huì)集群部署。由于網(wǎng)絡(luò)原因或者自身的原因，服務(wù)并不能保證100%可用，如果單個(gè)服務(wù)出現(xiàn)問(wèn)題，調(diào)用這個(gè)服務(wù)就會(huì)出現(xiàn)線程阻塞，此時(shí)若有大量的請(qǐng)求涌入，Servlet容器的線程資源會(huì)被消耗完畢，導(dǎo)致服務(wù)癱瘓。服務(wù)與服務(wù)之間的依賴性，故障會(huì)傳播，會(huì)對(duì)整個(gè)微服務(wù)系統(tǒng)造成災(zāi)難性的嚴(yán)重后果，這就是服務(wù)故障的“雪崩”效應(yīng)。

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

一、斷路器簡(jiǎn)介

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開(kāi)源了Hystrix組件，實(shí)現(xiàn)了斷路器模式，SpringCloud對(duì)這一組件進(jìn)行了整合。在微服務(wù)架構(gòu)中，一個(gè)請(qǐng)求需要調(diào)用多個(gè)服務(wù)是非常常見(jiàn)的，如下圖：

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

斷路打開(kāi)后，可用避免連鎖故障，fallback方法可以直接返回一個(gè)固定值。

二、準(zhǔn)備工作

這篇文章基于上一篇文章的工程，首先啟動(dòng)上一篇文章的工程，啟動(dòng)eureka-server?工程；啟動(dòng)service-hi工程，它的端口為8762。

三、在ribbon使用斷路器

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

org.springframework.cloud

spring-cloud-starter-hystrix

在程序的啟動(dòng)類ServiceRibbonApplication?加@EnableHystrix注解開(kāi)啟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注解。該注解對(duì)該方法創(chuàng)建了熔斷器的功能，并指定了fallbackMethod熔斷方法，熔斷方法直接返回了一個(gè)字符串，字符串為”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!";

}

}

啟動(dòng)：service-ribbon?工程，當(dāng)我們?cè)L問(wèn)http://localhost:8764/hi?name=forezp,瀏覽器顯示：

hi forezp,i am from port:8762

此時(shí)關(guān)閉service-hi?工程，當(dāng)我們?cè)僭L問(wèn)http://localhost:8764/hi?name=forezp，瀏覽器會(huì)顯示：

hi ,forezp,orry,error!

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

四、Feign中使用斷路器

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

feign.hystrix.enabled=true

基于service-feign工程進(jìn)行改造，只需要在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需要實(shí)現(xiàn)SchedualServiceHi?接口，并注入到Ioc容器中，代碼如下：

@Component

public class SchedualServiceHiHystric implements SchedualServiceHi {

@Override

public String sayHiFromClientOne(String name) {

return "sorry "+name;

}

}

啟動(dòng)四servcie-feign工程，瀏覽器打開(kāi)http://localhost:8765/hi?name=forezp,注意此時(shí)service-hi工程沒(méi)有啟動(dòng)，網(wǎng)頁(yè)顯示：

sorry forezp

打開(kāi)service-hi工程，再次訪問(wèn)，瀏覽器顯示：

hi forezp,i am from port:8762

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

五、Hystrix Dashboard (斷路器：Hystrix?儀表盤(pán))

基于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

在主程序啟動(dòng)類中加入@EnableHystrixDashboard注解，開(kāi)啟hystrixDashboard：

@SpringBootApplication

@EnableDiscoveryClient

@EnableHystrix

@EnableHystrixDashboard

public class ServiceRibbonApplication {

..//代碼省略

}

打開(kāi)瀏覽器：訪問(wèn)http://localhost:8764/hystrix,界面如下：

點(diǎn)擊monitor stream，進(jìn)入下一個(gè)界面，訪問(wèn)：http://localhost:8764/hi?name=forezp

此時(shí)會(huì)出現(xiàn)監(jiān)控界面：

本文源碼下載：?https://github.com/forezp/SpringCloudLearning/tree/master/chapter4

方志朋簡(jiǎn)介：SpringCloud中國(guó)社區(qū)聯(lián)合創(chuàng)始人，博客訪問(wèn)量突破一千萬(wàn)，愛(ài)好開(kāi)源，熱愛(ài)分享，活躍于各大社區(qū)，保持著非常強(qiáng)的學(xué)習(xí)驅(qū)動(dòng)力，終身學(xué)習(xí)踐行者，終身學(xué)習(xí)受益者。目前就職于國(guó)內(nèi)某家知名互聯(lián)網(wǎng)保險(xiǎn)公司，擔(dān)任DEVOPS工程師，對(duì)微服務(wù)領(lǐng)域和持續(xù)集成領(lǐng)域研究較深，精通微服務(wù)框架SpringCloud

Spring 容器 Spring Cloud

版權(quán)聲明：本文內(nèi)容由網(wǎng)絡(luò)用戶投稿，版權(quán)歸原作者所有，本站不擁有其著作權(quán)，亦不承擔(dān)相應(yīng)法律責(zé)任。如果您發(fā)現(xiàn)本站中有涉嫌抄襲或描述失實(shí)的內(nèi)容，請(qǐng)聯(lián)系我們jiasou666@gmail.com 處理，核實(shí)后本網(wǎng)站將在24小時(shí)內(nèi)刪除侵權(quán)內(nèi)容。