快捷導(dǎo)航

詳解SpringCloud微服務(wù)架構(gòu)之Hystrix斷路器

更新時(shí)間：2018年01月10日 14:54:14 作者：Bob_F

本篇文章主要介紹了詳解SpringCloud微服務(wù)架構(gòu)之Hystrix斷路器，Hystrix是一個(gè)庫(kù)，通過(guò)添加延遲容差和容錯(cuò)邏輯來(lái)幫助您控制這些分布式服務(wù)之間的交互，有興趣的可以了解一下

一：什么是Hystrix

在分布式環(huán)境中，許多服務(wù)依賴(lài)項(xiàng)中的一些將不可避免地失敗。Hystrix是一個(gè)庫(kù)，通過(guò)添加延遲容差和容錯(cuò)邏輯來(lái)幫助您控制這些分布式服務(wù)之間的交互。Hystrix通過(guò)隔離服務(wù)之間的訪(fǎng)問(wèn)點(diǎn)，停止其間的級(jí)聯(lián)故障以及提供回退選項(xiàng)，從而提高系統(tǒng)的整體彈性。

Hystrix旨在執(zhí)行以下操作

1：對(duì)通過(guò)第三方客戶(hù)端庫(kù)訪(fǎng)問(wèn)（通常通過(guò)網(wǎng)絡(luò)）的依賴(lài)關(guān)系提供保護(hù)并控制延遲和故障。

2：隔離復(fù)雜分布式系統(tǒng)中的級(jí)聯(lián)故障。

3：快速發(fā)現(xiàn)故障，盡快恢復(fù)。

4：回退，盡可能優(yōu)雅地降級(jí)。

5：?jiǎn)⒂媒鼘?shí)時(shí)監(jiān)控，警報(bào)和操作控制。

二：為什么需要Hystrix?

大型分布式系統(tǒng)中，一個(gè)客戶(hù)端或者服務(wù)依賴(lài)外部服務(wù)，如果一個(gè)服務(wù)宕了，那么由于我們?cè)O(shè)置了服務(wù)調(diào)用系統(tǒng)超時(shí)時(shí)間，勢(shì)必會(huì)影響相應(yīng)時(shí)間，在高并發(fā)的情況下大多數(shù)服務(wù)器的線(xiàn)程池就出現(xiàn)阻塞(BLOCK),影響整個(gè)線(xiàn)上服務(wù)的穩(wěn)定性。

(圖片官方圖片)

當(dāng)一切都健康時(shí)，請(qǐng)求可以看起來(lái)像這樣

當(dāng)許多后端服務(wù)系統(tǒng)中的一個(gè)宕掉時(shí)，整個(gè)用戶(hù)請(qǐng)求：

如果多個(gè)客戶(hù)端調(diào)用同一個(gè)異常服務(wù)的時(shí)候，出現(xiàn)的情況是：

三：Hystrix解決什么問(wèn)題？

分布式架構(gòu)中的應(yīng)用程序具有幾十個(gè)依賴(lài)關(guān)系，每個(gè)依賴(lài)關(guān)系在某個(gè)時(shí)刻將不可避免的出現(xiàn)異常。如果應(yīng)用程序不與這些外部故障隔離，則可能出現(xiàn)線(xiàn)程池阻塞，引起系統(tǒng)雪崩。

例如，對(duì)于依賴(lài)30個(gè)服務(wù)的應(yīng)用程序，每個(gè)服務(wù)的正常運(yùn)行時(shí)間為99.99％，您可以：

99.99%的30次方 = 99.7％正常運(yùn)行時(shí)間

0.3％的10億次請(qǐng)求= 3,000,000次故障

2+小時(shí)宕機(jī)/月，即使所有依賴(lài)關(guān)系正常運(yùn)行時(shí)間。

當(dāng)使用Hystrix進(jìn)行熔斷后，每個(gè)依賴(lài)關(guān)系彼此隔離了，限制了當(dāng)發(fā)生延遲時(shí)的阻塞。

四：Hystrix結(jié)合Feign使用

創(chuàng)建一個(gè)工程eureka_feign_hystrix_client

pom.xml文件內(nèi)容

<dependencies>

    <dependency>

      <groupId>org.springframework.cloud</groupId>

      <artifactId>spring-cloud-starter-feign</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.cloud</groupId>

      <artifactId>spring-cloud-starter-eureka</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-web</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-actuator</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-test</artifactId>

      <scope>test</scope>

    </dependency>

  </dependencies>

  <dependencyManagement>

    <dependencies>

      <dependency>

        <groupId>org.springframework.cloud</groupId>

        <artifactId>spring-cloud-dependencies</artifactId>

        <version>Brixton.SR5</version>

        <type>pom</type>

        <scope>import</scope>

      </dependency>

    </dependencies>

  </dependencyManagement>

創(chuàng)建啟動(dòng)文件

FeignHystrixApplication

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class FeignHystrixApplication {
  public static void main(String[] args) {

    SpringApplication.run(FeignHystrixApplication.class, args);
  }
}

UserClient類(lèi)

@FeignClient(value = "biz-service-0",fallback = UserClientHystrix.class)
public interface UserClient {
  @RequestMapping(method = RequestMethod.GET, value = "/getuser")
  public User getuserinfo();
  @RequestMapping(method = RequestMethod.GET, value = "/getuser")
  public String getuserinfostr();
  @RequestMapping(method = RequestMethod.GET, value = "/info")
  public String info();
}

創(chuàng)建熔斷類(lèi)UserClientHystrix

@Service
public class UserClientHystrix implements UserClient {

   @Override
  public User getuserinfo() {
    throw new NullPointerException(" User getuserinfo() 服務(wù)不可用。。");

  }

  @Override
  public String getuserinfostr() {
    return " UserClientHystrix getuserinfostr() is fallback 服務(wù)不可用。。";

  }

  @Override
  public String info() {
    return " UserClientHystrix info() is fallback 服務(wù)不可用。。";

  }
}

當(dāng)網(wǎng)絡(luò)出現(xiàn)異常的時(shí)候或直接跳轉(zhuǎn)到這里實(shí)現(xiàn)類(lèi)里面

創(chuàng)建action類(lèi)

UserController

@Autowired
  UserClient userClient;

  @RequestMapping(value = "/getuserinfo", method = RequestMethod.GET)
  public User getuserinfo() {
    return userClient.getuserinfo();
  }

  @RequestMapping(value = "/getuserinfostr", method = RequestMethod.GET)
  public String getuserinfostr() {
    return userClient.getuserinfostr();
  }

  @RequestMapping(value = "/info", method = RequestMethod.GET)
  public String info() {
    return userClient.info();
  }

先啟動(dòng)：eureka_register_service（注冊(cè)中心）工程

然后運(yùn)行我們寫(xiě)好的FeignHystrixApplication

這個(gè)時(shí)候我們明顯發(fā)現(xiàn)沒(méi)有運(yùn)行biz-service-0 服務(wù)，那么我們打開(kāi) http://127.0.0.1:8005/getuserinfostr

出現(xiàn)

UserClientHystrix getuserinfostr() is fallback 服務(wù)不可用。。

這個(gè)就是我們自定義的熔斷返回結(jié)果

如果不用熔斷頁(yè)面會(huì)出現(xiàn)這個(gè)

Whitelabel Error Page

This application has no explicit mapping for /error, so you are seeing this as a fallback.

Wed Mar 22 14:32:21 CST 2017

There was an unexpected error (type=Internal Server Error, status=500).

getuserinfo failed and fallback failed.

代碼地址：https://github.com/zhp8341/SpringCloudDemo

本人也看了一些Hystrix相關(guān)原理，由于沒(méi)有全部看完所以暫時(shí)沒(méi)有寫(xiě)上去，本文是結(jié)合Feign使用和學(xué)習(xí)。

有興起的可以看下官方的Hystrix很詳細(xì)，就是看起來(lái)有點(diǎn)費(fèi)勁，

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: