前言:微服務架構應用的特點就是多服務,而服務層之間通過網絡進行通信,從而支撐起整個應用系統,所以,各個微服務之間不可避免的存在耦合依賴關系。但任何的服務應用實例都不可能永遠的健康或網絡不可能永遠的都相安無事,所以一旦某個服務或局部業務發生了故障,會導致系統的不可用,我們知道當故障累積到一定程度就會造成系統層面的災害,也就是級聯故障,也叫雪崩效應,所以微服務需要在故障累計到上限之前阻止或疏通這些故障以保證系統的穩固安全,在市面上已經有很多這樣的框架來解決這樣的問題,如Twitter的Finagle、Netflix的Hystrix和Google的Stubby等,下面就簡單介紹下Hystrix和Hystrix在SpringCloud中的應用。
一、Hystrix簡介
Hystrix(https://github.com/Netflix/Hystrix)是由Netflix開源的一個延遲和容錯庫,用於隔離訪問遠程系統、服務或者第三方庫,防止級聯失敗,從而提升系統的可用性、容錯性與局部應用的彈性,是一個實現了超市機制和斷路器模式的工具類庫。
二、Hystrix如何解決依賴隔離
1、包裹請求:使用HystrixCommand包裹對依賴的調用邏輯,每個命令在獨立的線程中執行,使用了設計模式中的“命令模式”;
2、跳閘機制:當某服務的錯誤率超過一定閾值時,Hystrix可以自動或者手動跳閘,停止請求該服務一段時間;
3、資源隔離:Hystrix為每個依賴都維護了一個小型的線程池(或者信號量)。如果該線程已滿,則發向該依賴的請求就會被立即拒絕,而不是排隊等候,從而加速失敗判定;
4、監控:Hystrix可以近乎實時地監控運行指標和配置的變化,例如成功、失敗、超時、以及被拒絕的請求等;
5、回退機制:當請求失敗、超時、被拒絕,或當斷路器打開時,執行回退邏輯,回退邏輯由開發人員自行提供,如返回一個缺省值;
6、自我修復:斷路器打開一段時間后,會自動進入“半開”狀態,此時斷路器可允許一個請求訪問依賴的服務,若請求成功,則斷路器關閉,否則斷路器轉為“打開”狀態;
三、Hystrix在SpringCloud中的簡單應用
1、簡單整合Hystrix(在這部分會用到Ribbon測試的相關項目)
①、創建基於Eureka和Ribbon的服務端 eureka-ribbon-server和兩個客戶端生產者 eureka-ribbon-client2、消費者:復制項目eureka-ribbon-client,將AritfactId修改為eureka-hystrix-client;
②、在消費者中添加依賴:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
③、在啟動類ClientApplication上添加@EnableHystrix或@EnableCircuitBreaker;
④、修改HystrixController,在其中添加getUser方法,並添加熔斷回調方法注解及回調方法:
@HystrixCommand(fallbackMethod = "getDefaultUser")
@RequestMapping("/getUser")
public String getUser() {
return restTemplate.getForObject("http://client-87/getUser", String.class);
}
private String getDefaultUser() {
System.out.println("熔斷,默認回調函數");
return "{\"username\":\"admin\",\"age\":\"-1\"}";
}
⑤、分別啟動eureka-ribbon-server、eureka-ribbon-client2、eureka-hystrix-client,調用localhost:8765/getUser,如圖:
⑥、關掉eureka-ribbon-client2后,再次調用,發現熔斷器調用了回調函數,如圖:
關於Hystrix的配置屬性,可以自行測試了解:https://github.com/Netflix/Hystrix/tree/master/hystrix-contrib/hystrix-javanica#configuration
而我們如何知道hystrix是否開啟,可以通過SpringBoot Actuator組件查看,注意:出發回調並不是hystrix打開,他的狀態還處在關閉,若失敗率達到閾值(默認為5秒內20次失敗)后才會打開;
2、基於Feign使用Hystrix
通常情況下的Hystrix是通過注解@HystrixCommand的fallbackMethod屬性實現回調的,而在Feign中,由於Feign是用借口實現的聲明式Rest,所以Hystrix的通用方法在這里就不適用於Feign了,實際上在Feign與SpringCloud的依賴庫中已經默認的將Hystrix加入其中了,如圖:
那么,該怎么實現呢?
- 將上面通用Hystrix的項目中的消費者模塊修改為,由於feign中已經集成了hystrix類庫,所以就不需要重復導入了:
pom.xml:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
application.properties屬性配置文件:
server.port=8762
spring.application.name=client-8762
#默認feign的hystrix為關閉狀態
feign.hystrix.enabled=true
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
啟動類添加@EnableFeignClients,控制層通過注入feign的接口去完成聲明式調用:
feign的接口:
package com.cn.feign; import org.springframework.cloud.netflix.feign.FeignClient; import org.springframework.web.bind.annotation.RequestMapping; //接口類上加入的注解中添加屬性fallback,指定回調類 @FeignClient(name = "CLIENT-87",fallback = FeignClientFallback.class) public interface UserFeign { @RequestMapping("/getUser") public String getUser(); }
創建回調類:
package com.cn.feign; import org.springframework.stereotype.Component; /** * @Description: 回調實現類 * @Param: * @return: * @Author: * @Date: 2018/6/19 */ @Component class FeignClientFallback implements UserFeign { @Override public String getUser() { System.out.println("熔斷,默認回調函數"); return "{\"username\":\"admin\",\"age\":\"-1\"}"; } }
2.測試結果如下:
在未關閉生產者服務實例時:
關閉實例后:
代碼示例:https://gitee.com/lfalex/springcloud-example( eureka-hystrix-client、 eureka-feign-hystrix-client、 eureka-ribbon-client2、 eureka-ribbon-server)
參考書籍:《SpringCloud與Docker微服務架構實戰》周力著