一文讀懂Spring Cloud-Hystrix

Posted on by

Hystrix概述

Hystrix：斷路器，容錯管理工具，旨在通過熔斷機制控制服務和第三方庫的節點,從而對延遲和故障提供更強大的容錯能力。

hystrix可以實現降級和熔斷：

  • 降級

調用遠程服務失敗（宕機、500錯、超時），可以降級執行當前服務中的一段代碼，向客戶端返回結果

快速失敗

  • 熔斷

當訪問量過大，出現大量失敗，可以做過熱保護，斷開遠程服務不再調用

限流

防止故障傳播、雪崩效應

在微服務系統中，服務之間進行依賴，避免有調用其中服務失敗，而引起其他服務大范圍宕機，造成雪崩效應，hystrix熔斷可在滿足熔斷條件（默認10秒20次以上請求，同時50%失敗）後執行降級。快速斷開故障服務，保護其他服務不受影響。

降級

 

第一步：sp06添加hystrix依賴

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

第二步：主程序添加 @EnableCircuitBreaker 啟用 hystrix 斷路器

package cn.tedu.sp06;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;
@EnableCircuitBreaker
@SpringBootApplication
public class Sp06RibbonApplication {
  public static void main(String[] args) {
   SpringApplication.run(Sp06RibbonApplication.class, args);
  }
  /**
 * 創建RestTemplate實例
 * 放入spring容器
 * @LoadBalanced-對RestTemplate進行增強，封裝RestTemplate，添加負載均衡功能
 */
 @LoadBalanced
 @Bean public RestTemplate restTemplate(){
   //設置調用超時時間，超時後認為調用失敗
 SimpleClientHttpRequestFactory f =
      new SimpleClientHttpRequestFactory();
   f.setConnectTimeout(1000);//建立連接等待時間
 f.setReadTimeout(1000);//連接建立後，發送請求後，等待接收響應的時間
 return new RestTemplate(f);
  }
}

第三步：RibbonController 中添加降級方法

  • 為每個方法添加降級方法，例如 getItems() 添加降級方法 getItemsFB()
  • 添加 @HystrixCommand 註解，指定降級方法名
package cn.tedu.sp06.controller;
import cn.tedu.sp01.pojo.Item;
import cn.tedu.sp01.pojo.Order;
import cn.tedu.sp01.pojo.User;
import cn.tedu.web.util.JsonResult;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.util.List;
@RestController
@Slf4j
public class RibbonController {
  @Autowired
 private RestTemplate rt;
  @GetMapping("/item-service/{orderId}")
  @HystrixCommand(fallbackMethod = "getItemsFB") //指定降級方法的方法名
 public JsonResult<List<Item>> getItems(@PathVariable String orderId){
    return rt.getForObject("http://item-service/{1}", JsonResult.class,orderId);
  }
  @PostMapping("/item-service/decreaseNumber")
  @HystrixCommand(fallbackMethod = "decreaseNumberFB") //指定降級方法的方法名
 public JsonResult<?> decreaseNumber(@PathVariable List<Item> items){
    return rt.postForObject("http://item-service/decreaseNumber",items, JsonResult.class);
  }
  @GetMapping("/user-service/{userId}")
  @HystrixCommand(fallbackMethod = "getUserFB") //指定降級方法的方法名
 public JsonResult<User> getUser(@PathVariable Integer userId) {
    return rt.getForObject("http://user-service/{1}", JsonResult.class, userId);
  }
  @GetMapping("/user-service/{userId}/score")
  @HystrixCommand(fallbackMethod = "addScoreFB") //指定降級方法的方法名
 public JsonResult addScore(
      @PathVariable Integer userId, Integer score) {
    return rt.getForObject("http://user-service/{1}/score?score={2}", JsonResult.class, userId, score);
  }
  @GetMapping("/order-service/{orderId}")
  @HystrixCommand(fallbackMethod = "getOrderFB") //指定降級方法的方法名
 public JsonResult<Order> getOrder(@PathVariable String orderId) {
    return rt.getForObject("http://order-service/{1}", JsonResult.class, orderId);
  }
  @GetMapping("/order-service")
  @HystrixCommand(fallbackMethod = "addOrderFB") //指定降級方法的方法名
 public JsonResult addOrder() {
    return rt.getForObject("http://order-service/", JsonResult.class);
  }
  //降級方法的參數和返回值，需要和原始方法一致，方法名任意
 public JsonResult<List<Item>> getItemsFB(String orderId) {
    return JsonResult.err("獲取訂單商品列表失敗");
  }
  public JsonResult decreaseNumberFB(List<Item> items) {
    return JsonResult.err("更新商品庫存失敗");
  }
  public JsonResult<User> getUserFB(Integer userId) {
    return JsonResult.err("獲取用戶信息失敗");
  }
  public JsonResult addScoreFB(Integer userId, Integer score) {
    return JsonResult.err("增加用戶積分失敗");
  }
  public JsonResult<Order> getOrderFB(String orderId) {
    return JsonResult.err("獲取訂單失敗");
  }
  public JsonResult addOrderFB() {
    return JsonResult.err("添加訂單失敗");
  }
}

第四步：啟動eureka、item和hystrix服務器進行測試

http://localhost:3001/item-service/35

hystrix超時設置：

超時時間設置應該超過ribbon重試時間，否則重試失效。

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds

hystrix等待超時後, 會執行降級代碼, 快速向客戶端返回降級結果, 默認超時時間是1000毫秒。

可在yml中設置超時時間：

hystrix:
 command:
  default:
   execution:
    isolation:
     thread:
      timeoutInMilliseconds: 6000

熔斷

主程序添加 @EnableCircuitBreaker 啟用 hystrix 斷路器，熔斷自動打開。

Hystrix故障監控-Hystrix Dashboard斷路器儀表盤

Hystrix使用springboot提供的actuator健康管理，監控各個端點。

actuator中的hystrix.stream可以監控hystrix斷路器各端點日志。

第一步：sp06的pom中添加actuator依賴

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-actuator</artifactId>
  <version>2.4.0</version>
</dependency>

第二步：在yml中配置健康監控的內容

# "*"暴露所有監控端點
management:
 endpoints:
  web:
   exposure:
    include: "*"

第三步：測試actuator健康監控

http://localhost:3001/actuator/ 搭建Hystrix Dashboard儀表盤：

儀表盤項目是一個完全獨立的項目。

第一步：創建springboot項目sp08-htstrix-dashboard

第二步：添加hystrix dashboard依賴

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>

第三步：主程序上添加@EnableHystrixDashboard註解

package cn.tedu.sp08;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@EnableHystrixDashboard
@SpringBootApplication
public class Sp08HystrixDashboardApplication {
  public static void main(String[] args) {
   SpringApplication.run(Sp08HystrixDashboardApplication.class, args);
  }
}

第四步：配置允許給那些服務器開啟權限

hystrix:
 dashboard:
  proxy-stream-allow-list: localhost

第五步：監控查看

http://localhost:4001/hystrix/

第六步：查看hystrix stream監控數據端點

輸入hystrix監控地址

訪問item/user/order服務器，查看儀表盤。

第六步：使用ab進行並發訪問測試

使用 apache 的並發訪問測試工具 ab進行訪問測試。

打開ab工具/bin文件目錄–cmd–輸入命令：

ab -n 20000 -c 50 http://localhost:3001/item-service/35

並發50，發送20000個請求，查看儀表盤。

到此這篇關於一文讀懂Spring Cloud-Hystrix的文章就介紹到這瞭,更多相關Spring Cloud Hystrix內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：