一起來學Spring Cloud | 第五章:熔斷器 ( Hystrix)


在微服務項目中,一個系統可以分割成很多個不同的服務模塊,不同模塊之間我們通常需要進行相互調用。springcloud中可以使用RestTemplate+Ribbon和Feign來調用(工作中基本都是使用feign)。有時為了提高系統的健壯性,某些訪問量大的服務模塊還會做集群部署。但是服務之間的調用不可能百分之百成功的,如果出現超時、異常會導致服務無法提供功能。這時如果有大量請求訪問異常服務,就會造成系統資源耗盡,導致服務癱瘓。服務與服務之間的依賴性,故障會傳播,會對整個微服務系統造成災難性的嚴重后果,這就是服務故障的“雪崩”效應。在實際工作中,復雜的系統往往有成百上千個服務模塊,某個功能模塊出現異常,不能影響其它功能的正常運行,所以熔斷器Hystrix就派上用場了。

一、Hystrix簡介:

Hystrix由Netfilix API團隊研發於2011年,2012年開始在Hystrix公司內部推廣和使用,Hystrix在Netflix中久經沙場,現在已經是一個非常成熟的系統,而最近流行的微服務架構和Spring Cloud,讓Hystrix成為了配套的基礎設施,在國內也逐漸流行起來。

hystrix的出現即為解決服務雪崩效應,它通過四個方面的機制來解決這個問題

1. 隔離(線程池隔離和信號量隔離):限制調用分布式服務的資源使用,某一個調用的服務出現問題不會影響其他服務調用。

2. 降級:超時降級、資源不足時(線程或信號量)降級,降級后可以配合降級接口返回托底數據。

3. 熔斷:當失敗率達到閥值自動觸發降級(如因網絡故障/超時造成的失敗率高),熔斷器觸發的快速失敗會進行快速恢復。

4. 緩存:提供了請求緩存、請求合並實現。

如果想要了解更多的Hystrix的底層及實現原理,可以參考相關文章學習,本系列主要講解如何快速在工作中使用Hystrix。

二、環境准備:

最終目錄結構:

 

本系列文章,都是層層遞進的,本章內容在前面搭建好的項目框架上進行開發講解,對搭建springcloud的多模塊子項目框架不清楚的同學可以參考一起來學Spring Cloud | 第一章 :如何搭建一個多模塊的springcloud項目 

工作中,我們基本上都是使用feign進行服務調用的,所以本章只講解Feign中使用斷路器,對上一章feign工程搭建有興趣的可以參考:一起來學Spring Cloud | 第四章:服務消費者 ( Feign )

三、Feign中使用斷路器:

1. 在上章的springcloud-feign-client工程的application.properties配置文件中,加入配置:feign.hystrix.enabled=true

server.port=9600
spring.application.name=springcloud-feign-client
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
feign.hystrix.enabled=true

2. 在上章的springcloud-feign-client工程中,新增一個FeignRemoteService類的實現類,命名為:HystrixFeignRemoteCallBack,做為出現接口異常時的回調方法

package com.haly.romote.hystrix;

import org.springframework.stereotype.Component;

import com.haly.romote.FeignRemoteService;

@Component
public class HystrixFeignRemoteCallBack implements FeignRemoteService{

	@Override
	public String hello(String name) {
		// TODO Auto-generated method stub
		return name + ",Due error,enter Hystrix";
	}

}

3. 在上章的springcloud-feign-client工程中,新增一個FeignRemoteService類中加入回調實現類的注解配置

package com.haly.romote;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;

import com.haly.romote.hystrix.HystrixFeignRemoteCallBack;

@FeignClient(value = "springcloud-eureka-client",fallback = HystrixFeignRemoteCallBack.class)
public interface FeignRemoteService {

    @RequestMapping(value = "/hello",method = RequestMethod.GET)
    public String hello(@RequestParam(value = "name") String name);
    
}

4. 運行項目

① 先啟動springcloud-eureka-server模塊,開啟eureka注冊中心

② 啟動springcloud-eureka-client模塊,開啟提供遠程服務功能,並且提供接口能力 /hello

③ 啟動springcloud-feign-client模塊,開啟消費模塊,用來調用springcloud-eureka-client模塊中的/hello接口

Eureka上的注冊信息,如下圖:

打開瀏覽器,輸入網址:http://localhost:9600/getHello?name=young碼農,運行結果如下:

我們模仿生產環境,服務提供者宕機(或者返回超時),這里我們手動停掉springcloud-eureka-client服務

輸入網址:http://localhost:9600/getHello?name=young碼農

本章我們只是在回調接口中,返回一個字符串,工作中,有些場景會做一些業務邏輯處理(比如調用短信發送接口,出現異常會在記錄一條異常日志,后面來處理這些異常)。

工作中我們會遇到很多特殊場景,特別在訪問量過大,業務較復雜的時候,會出現一些奇奇怪怪的問題,所以Feign,Hystrix有許多配置項可以使用,我們可以根據相應業務配進行合理配置

 

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM