腳本之家服務器常用軟件

快捷導航

SpringCloud之微服務容錯的實現(xiàn)

更新時間：2019年05月01日 14:50:48 作者：卿亦離

這篇文章主要介紹了SpringCloud之微服務容錯的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

1.雪崩效應

雪崩效應

如上圖所示，假設我們有3個微服務A，B，C，A調(diào)用B，B調(diào)用C，如果C掛掉了，由于B是同步調(diào)用，不斷等待，導致資源耗盡，B也掛掉，接下來A也掛掉了，造成了雪崩效應！為了防止雪崩效應，所以我們要在本篇文章中介紹Hystrix。

2.Hystrix

Hystrix

hystrix對應的中文名字是“豪豬”,豪豬周身長滿了刺,能保護自己不受天敵的傷害,代表了一種防御機制，反正這種豬我是沒吃過的，不敢吃。那么Hystrix又具備什么樣的特點呢：

2.1服務降級

雙11的時候我們經(jīng)?？吹桨驯粩D爆了，這其實就是一種服務降級。那么Hystrix是怎么做到服務降級的呢？

2.1.1優(yōu)先核心服務，非核心服務不可用或者弱可用

比如在一個系統(tǒng)中我們可能有限保證訂單和支付服務，但是對于廣告之類的服務就若花掉

2.1.2通過HystrixCommand注解

2.1.3fallbackMethod中具體實現(xiàn)降級邏輯

2.1.4具體使用

2.1.4.1pom.xml

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

2.1.4.2啟動類

//@SpringBootApplication
//@EnableDiscoveryClient
//@EnableCircuitBreaker
@SpringCloudApplication
public class OrderApplication {

  public static void main(String[] args) {
    SpringApplication.run(OrderApplication.class, args);
  }
}

在這里我們引入了@EnableCircuitBreaker這個注解，但是可以看到我們的main函數(shù)所在的類上面有好多注解了，我們這里用一個SpringCloudApplication注解包含上面的3個注解

2.1.4.3HystrixCommand與fallback的使用

 @HystrixCommand(fallbackMethod="fallback")
  @GetMapping("/getProductInfoList")
  public String getProductInfoList(@RequestParam("number") Integer number) {
    RestTemplate restTemplate = new RestTemplate();
    return restTemplate.postForObject("http://127.0.0.1:8005/product/listForOrder",
        Arrays.asList("157875196366160022"),
        String.class);
  }

  private String fallback() {
    return "太擁擠了, 請稍后再試~~";
  }

假設你的方法有幾萬個，上面的這種寫法用@HystrixCommand這個注解肯定要用幾萬次，太麻煩了，我們來優(yōu)化和更新一下：

@RestController
@DefaultProperties(defaultFallback = "defaultFallback")
public class HystrixController {

  @HystrixCommand(commandProperties = {
      @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")
  })
  @GetMapping("/getProductInfoList")
  public String getProductInfoList(@RequestParam("number") Integer number) {
    RestTemplate restTemplate = new RestTemplate();
    return restTemplate.postForObject("http://127.0.0.1:8005/product/listForOrder",
        Arrays.asList("157875196366160022"),
        String.class);
  }

  private String defaultFallback() {
    return "默認提示：太擁擠了, 請稍后再試~~";
  }
}

直接在Controller上面寫了一個DefaultProperties這樣的注解，然后定義了一個defaultFallback這樣的方法，我們在getProductInfoList這個方法上的@HystrixCommand注解上可以不在注明fallback方法了，因為我們都用defaultFallback了。但是在這里我們用了一個commandProperties = {

@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")，這個表示當調(diào)用方法超過3秒鐘時，就服務降級

2.2依賴隔離

Hystrix使用依賴隔離完成的是線程池的隔離，它為每個HystrixCommand創(chuàng)建一個單獨的線程池。這樣某個在HystrixCommand包裝下的依賴服務出現(xiàn)延遲過高的情況，也只是對該依賴的服務調(diào)用產(chǎn)生影響，并不會拖慢其他服務。使用了HystrixCommand將某個函數(shù)包裝成Hystrix命令時，Hystrix框架就會自動的為這個函數(shù)實現(xiàn)了依賴隔離，所以依賴隔離和服務降級是一體化實現(xiàn)的。

2.3服務熔斷

當服務調(diào)用發(fā)生錯誤到一定比例的時候，斷路器就會打開，服務的調(diào)用會轉向另外一個指定的調(diào)用方法，這就是服務熔斷，這樣說比較抽象，我們看看下面這個圖：

斷路器

斷路器一共有三個狀態(tài)，初始的時候是closed狀態(tài)，如果用戶不斷調(diào)用且失敗次數(shù)達到了一定的閾值，這個時候斷路器就會變成open狀態(tài)，接下來用戶不斷調(diào)用這個接口都是進入到另一個缺省方法中。但是斷路器不會一直處于open狀態(tài)，當open狀態(tài)達到一定時間后，斷路器會變成half open狀態(tài)，進入half open狀態(tài)后，將會允許請求再次訪問真正的服務，如果訪問成功了，斷路器會變成closed狀態(tài)，服務恢復正常，如果還失敗又再次進入到open狀態(tài)。

2.3.1代碼演示

  @HystrixCommand(commandProperties = {
      @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),         //設置熔斷
      @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"), //請求數(shù)達到后才計算
      @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"), //休眠時間窗
      @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60"),  //錯誤率
  })
  @GetMapping("/getProductInfoList")
  public String getProductInfoList(@RequestParam("number") Integer number) {
    if (number % 2 == 0) {
      return "success";
    }

    RestTemplate restTemplate = new RestTemplate();
    return restTemplate.postForObject("http://127.0.0.1:8005/product/listForOrder",
        Arrays.asList("157875196366160022"),
        String.class);
  }

通過代碼，我們可以看到，有四個參數(shù)，但是最重要的還是這三個參數(shù)：

1.circuitBreaker.requestVolumeThreshold 請求數(shù)達到后才計算

2.circuitBreaker.sleepWindowInMilliseconds open狀態(tài)達到這個時間后，就會進入到半熔斷狀態(tài)

3.circuitBreaker.errorThresholdPercentage 失敗請求比例

2.3.2使用配置項

從上面的代碼中，我們可以看到，很多配置項都是寫在了代碼里面，接下來，我們把這些配置放到配置文件里面去：

@HystrixCommand
  @GetMapping("/getProductInfoList")
  public String getProductInfoList(@RequestParam("number") Integer number) {
    if (number % 2 == 0) {
      return "success";
    }

    RestTemplate restTemplate = new RestTemplate();
    return restTemplate.postForObject("http://127.0.0.1:8005/product/listForOrder",
        Arrays.asList("157875196366160022"),
        String.class);
  }

在yaml文件中添加這樣的配置：

hystrix:
 command:
  default:
   execution:
    isolation:
     thread:
      timeoutInMilliseconds: 1000
  getProductInfoList:
   execution:
    isolation:
     thread:
      timeoutInMilliseconds: 3000

在yaml文件中有一個getProductInfoList配置項，和方法名一模一樣，還有一個default選項，default選項表示所有被HystrixCommand注解的方法都可以用這個配置，getProductInfoList表示只有這個方法可以用這個配置項。

2.3.3feign-hystrix的使用

上面的小章節(jié)我們使用的是RestTemplate模板，接下來我們使用feign配合hystrix來進行使用，有意思的是大家可以看看spring-cloud-starter-feign的pom.xml其實已經(jīng)在內(nèi)部依賴了hystrix。

2.3.3.1yaml配置文件

feign:
 hystrix:
  enabled: true

2.3.3.2FeignClient

@FeignClient(name = "product", fallback = ProductClient.ProductClientFallback.class)
public interface ProductClient {

  @PostMapping("/product/listForOrder")
  List<ProductInfoOutput> listForOrder(@RequestBody List<String> productIdList);

  @PostMapping("/product/decreaseStock")
  void decreaseStock(@RequestBody List<DecreaseStockInput> decreaseStockInputList);

  @Component
  static class ProductClientFallback implements ProductClient {

    @Override
    public List<ProductInfoOutput> listForOrder(List<String> productIdList) {
      return null;
    }

    @Override
    public void decreaseStock(List<DecreaseStockInput> decreaseStockInputList) {

    }
  }
}

兩個注意點，一個是fallback的配置，還有一個是內(nèi)部類需要加上@Component注解

2.3.3.3調(diào)用方記得加上ComponentScan

2.4監(jiān)控HystrixDashBoard

2.4.1pom.xml

spring-cloud-starter-hystrix-dashboard

2.4.2yaml文件