玩轉Spring Cloud之熔斷降級（Hystrix）與監控

時間 2019-11-06

標籤 spring cloud 熔斷降級 hystrix 監控欄目 Spring 简体版

原文原文鏈接

本文內容導航目錄：html

前言：解釋熔斷降級
 1、搭建服務消費者項目，並集成 Hystrix環境
　　1.1.在POM XML中添加Hystrix依賴(spring-cloud-starter-netflix-hystrix)
　　1.2.採用Ribbon + Hystrix的方式
　　 1.3.採用Feign + Hystrix方式
 2、集成Hystrix-dashboard熔斷監控面板
　　2.1.在POM XML中添加Hystrix Dashboard依賴、actuator依賴
　　 2.2.在spring boot啓動類上再添加：@EnableHystrixDashboard註解，而後添加註冊HystrixMetricsStreamServlet的方法
　　 2.3.單獨搭建一個專門用於查詢每一個項目監控數據的項目
 3、經過引入Turbine聚合熔斷監控數據以便統一集中查看
　　3.1.在POM XML添加以下turbine依賴
　　 3.2 在spring boot啓動類上標註@EnableTurbine，並再添加註冊HystrixMetricsStreamServlet的方法
　　 3.3.在application.yml配置中增長turbine相關的參數設置java

前言：git

爲了防止服務消費鏈（多級服務之間的調用）上因某個服務出現故障，而致使級聯故障，進而形成整個系統不可用（簡稱爲：雪崩效應），推出了熔斷、降級的處理方式：Hystrix斷路器（相似生活中電路保險絲）來解決這些潛在問題。github

熔斷、降級是兩個概念，網上也有不少相關的說明，我這裏簡單通俗說明一下：web

熔斷：當服務消費鏈上，下游服務因訪問壓力過大而出現響應變慢或失敗不可用，上游服務爲了保護系統總體的可用性（避免無效重試及長時等待等狀況），能夠暫時切斷對下游服務的調用，直接快速返回錯誤的響應信息，當檢測到該下游服務節點調用響應正常後再恢復消費鏈路。這個過程能夠經過以下圖形象說明：（圖片來自http://www.ityouknow.com/springcloud/2017/05/16/springcloud-hystrix.html，文中也有說明）spring

熔斷關閉狀態（Closed）：服務沒有故障時，熔斷器所處的狀態，對調用方的調用不作任何限制。express

熔斷開啓狀態（Open）：在固定時間窗口內（Hystrix默認是10秒），接口調用出錯比率達到一個閾值（Hystrix默認爲50%），會進入熔斷開啓狀態。進入熔斷狀態後，後續對該服務接口的調用再也不通過網絡，直接執行本地的fallback方法。apache

半熔斷（半開啓）狀態（Half-Open）：在進入熔斷開啓狀態一段時間以後（Hystrix默認是5秒），熔斷器會進入半熔斷狀態。所謂半熔斷就是嘗試恢復服務調用，容許有限的流量調用該服務，並監控調用成功率。若是成功率達到預期，則說明服務已恢復，進入熔斷關閉狀態；若是成功率仍舊很低，則從新進入熔斷關閉狀態。網絡

降級：下降服務標準以知足核心重要服務正常運轉，詳情的說明請參見：https://blog.51cto.com/8132260/2133705併發

Hystrix是什麼，具體工做原理請參見：Netflix Hystrix斷路器簡介與工做原理

Tips：咱們在項目中常常須要添加不少的maven依賴，依賴組件（或稱類庫）的名字可能各不相同，咱們能夠經過以下方式查詢相關的maven依賴包及其依賴包自己的內部依賴詳情

經過官網：http://mvnrepository.com/，或者：https://search.maven.org/

1、搭建服務消費者項目，並集成 Hystrix環境

　　請參見上篇《玩轉Spring Cloud之服務註冊發現（eureka）及負載均衡消費（ribbon、feign）》搭建註冊中心，服務提供者，服務消費者，本文仍然使用上篇文章中所建立的服務消費者demo項目：eurekaclientconsumer

　　1.1.在POM XML中添加Hystrix依賴(spring-cloud-starter-netflix-hystrix)，配置以下：

<!-- 這裏dependencyManagement附帶貼出來，目的是說明若是不輸version，想實現依賴繼承，就須要這個，若是PMO中已經有則可沒必要再重複添加-->    
<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

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

　　1.2.採用Ribbon + Hystrix的方式，在spring boot啓動類(EurekaclientconsumerApplication)上添加@EnableHystrix，並修改遠程服務調用類（HelloService），在相應的方法中添加@HystrixCommand註解並配置相關參數，具體實現代碼以下：

//spring boot啓動類：

package cn.zuowenjun.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@EnableHystrix
@EnableDiscoveryClient
@SpringBootApplication
class EurekaclientconsumerApplication {

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

    @LoadBalanced
    @Bean
    public RestTemplate restTemplate(){
        return  new RestTemplate();
    }

}


//HelloService:遠程服務調用類

package cn.zuowenjun.cloud.service;


import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.HashMap;
import java.util.Map;

@Service
public class HelloService {

    @Autowired
    private RestTemplate restTemplate;

    @Value("${spring.application.helloServiceProvider}")
    private String  helloServiceName;

    @HystrixCommand(fallbackMethod = "multiplyFallback",
            commandProperties ={
                    @HystrixProperty(name = "execution.isolation.strategy", value = "SEMAPHORE"),
                    @HystrixProperty(name = "execution.isolation.semaphore.maxConcurrentRequests", value = "3")
            } )
    public Object multiply(int a,int b){
        String url="http://"+ helloServiceName +"/multiply/" + a +"/" + b;
        return restTemplate.getForObject(url,String.class);

//        throw new RuntimeException("consumer exception");
    }

    private  Object multiplyFallback(int x,int y,Throwable e){

        //TODO:額外增長的Throwable e，以即可以根據throwable的不一樣執行不一樣的邏輯
        Map<String,Object> result=new HashMap<String, Object>();
        result.put("from","multiply Fallback method");
        result.put("a",x);
        result.put("b",y);
        result.put("ex",e.getMessage());

        return  result;

    }


}

如上代碼，我先屏蔽掉了有關Feign的相關配置及代碼（其實能夠兼容並存，這裏只是爲了你們好理解纔去掉的），而後啓動類添加了@EnableHystrix、遠程服務類相關方法添加@HystrixCommand，並設置相關參數，其中fallbackMethod是比較重要的，它指示當出現熔斷後降級回調的方法名（注意該方法需與被標註@HystrixCommand接口方法簽名相同，但若是須要根據異常狀況執行不一樣的降級處理邏輯則可如demo中multiplyFallback額外添加一個Throwable 參數），commandProperties是比較複雜的，能夠包含不少的設置，如代碼中設置了資源隔離方式爲信號量並指定併發請求數，更多參數配置說明可參見：https://blog.csdn.net/tongtong_use/article/details/78611225，資源隔離策略說明參見：http://www.javashuo.com/article/p-mewxzsov-hm.html，有信號量、線程池兩種隔離方式，默認是線程池隔離，二者的區別以下圖示：（圖片來源：前面給出的連接文章，這裏重點貼出說明）

最後直接啓動運行，如訪問：http://localhost:8666/x?a=23&b=56

當註冊中心、服務提供者都正常狀況下，能正常返回結果：

當註冊中心（消費者沒法從註冊中心獲取服務實例信息時）或服務提供者關閉掉，模擬網絡不可達，服務不可用的狀況，再次請求，返回熔斷降級回調方法的結果：

1.3.採用Feign + Hystrix方式

　　1.3.1首先定義一個實現自被@FeignClient標註的遠程調用服務接口類（HelloRemoteService）的Hystrix降級回調實現類：HelloRemoteServiceFallbackImpl，實現接口裏的相關方法，這裏的方法是與接口裏的同名方法有本質不一樣，接口裏的方法是映射請求遠程服務，而降級回調類中的方法是當接口中的同名方法調用失敗後觸發降級回調這些方法，因此這些是對應接口的降級方法。而後在遠程調用服務接口類（HelloRemoteService）的@FeignClient註解中添加相關的參數配置，其中很重要的依然是：fallback，這個是指定Hystrix降級回調實現類（即：HelloRemoteServiceFallbackImpl），最後確保spring boot啓動類上添加了@EnableFeignClients（這個是上篇就說過的，要想啓用Feign就得添加），具體代碼實現以下：

//HelloRemoteServiceFallbackImpl 降級回調實現類：
package cn.zuowenjun.cloud.service;

import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PathVariable;

import java.util.HashMap;
import java.util.Map;

@Component
public class HelloRemoteServiceFallbackImpl implements HelloRemoteService{

    @Override
    public Object multiply(@PathVariable("a") int x, @PathVariable("b") int y) {
        Map<String,Object> result=new HashMap<>();
        result.put("from","multiply Fallback method");
        result.put("a",x);
        result.put("b",y);

        return  result;
    }
}


//HelloRemoteService遠程調用服務類：

package cn.zuowenjun.cloud.service;


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


@FeignClient(name= "helloservice",fallback =HelloRemoteServiceFallbackImpl.class )
public interface HelloRemoteService {

    @RequestMapping("/multiply/{a}/{b}")
    Object  multiply(@PathVariable("a") int x, @PathVariable("b") int y);

}


//spring boot啓動類：
package cn.zuowenjun.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;


@EnableDiscoveryClient
@SpringBootApplication
@EnableFeignClients(basePackages = "cn.zuowenjun.cloud.service") // 若是啓動類不在根目錄須要指定basePackages，不然不須要
class EurekaclientconsumerApplication {

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


}

1.3.2.Feign雖然集成了Hystrix，但默認並未開啓，須要在配置文件中顯示配置開啓，application.yml配置以下：（固然我這裏依然如1.2同樣改變了默認的資源隔離方爲信號量）

server:
  port: 8666

spring:
  application:
    name: ribbonclient
    helloServiceProvider: helloservice #自定義配置，指定訪問遠程服務名稱，固然也能夠寫死在代碼中

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8800/eureka/ #指向eureka server


feign:
  hystrix:
    enabled: true #啓用hystrix
    command:
      default:
        execution:
          isolation:
            strategy: #默認是THREAD,這裏演示改爲了信號量隔離模式
              semaphore:
                maxConcurrentRequests: 3

經過如上兩步即完成了Feign集成Hystrix，啓動項目，如在註冊中心、服務提供者都正常的狀況下訪問：http://localhost:8666/multiply/66/88，就能獲得正常結果，不然當註冊中心（消費者沒法從註冊中心獲取服務實例信息時）、服務提供者任意節點出問題，則會執行降級回調方法，以下圖示：

、

雖然當服務提供者不可用時，經過fallback可以直接熔斷降級回調相關的方法，但有時若是咱們須要根據不一樣的異常執行不一樣的降級處理邏輯呢，該如何辦？這個時候可使用fallbackFactory來實現自定義的降級回調實例建立過程，從而能夠在create降級回調實現類時增長額外邏輯。實現步驟是：先建立實現自FallbackFactory的自定義降級回調工廠類：HystrixClientFallbackFactory,而後@FeignClient註解的fallbackFactory參數指向HystrixClientFallbackFactory.class便可，具體實現代碼以下：

package cn.zuowenjun.cloud.service;

import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@Component
public class HystrixClientFallbackFactory implements FallbackFactory<HelloRemoteService> {

    public HelloRemoteService create(Throwable throwable) {
        //TODO:這裏能夠根據throwable的不一樣生成不一樣的HelloRemoteService的Fallback的實例
        return  new HelloRemoteService() {//這裏是匿名實現接口，也能夠用lambda表達式或具體的接口實現類，如：HelloRemoteServiceFallbackImpl

            @Override
            public Object multiply(int x, int y) {
                //TODO:這裏能夠根據throwable的不一樣執行不一樣的邏輯
                Map<String,Object> result=new HashMap<>();
                result.put("from","multiply FallbackFactory method");
                result.put("a",x);
                result.put("b",y);
                result.put("ex",throwable.getMessage());
                return  result;
            }
        };
    }
}



package cn.zuowenjun.cloud.service;


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



//@FeignClient(name= "helloservice",fallback =HelloRemoteServiceFallbackImpl.class )
@FeignClient(name= "helloservice",fallbackFactory = HystrixClientFallbackFactory.class)
public interface HelloRemoteService {

    @RequestMapping("/multiply/{a}/{b}")
    Object  multiply(@PathVariable("a") int x, @PathVariable("b") int y);

}

最後從新啓動項目，並仍然訪問：http://localhost:8666/multiply/66/88，正常狀況都是OK的，當服務提供者不可用時，則會經過HystrixClientFallbackFactory工廠類建立降級回調實現類，並執行對應的降級方法，這裏能夠看到Throwable是create方法的入參，咱們能夠根據入參建立不一樣的降級回調實現類或實現不一樣的處理邏輯，這裏DEMO演示的降級回調結果以下圖示：

2、集成Hystrix-dashboard熔斷監控面板

　　如上第一部份演示效果，經過在服務消費者項目中集成Hystrix能夠作到依賴隔離、熔斷、降級處理等操做，但若是沒有有效的監控途徑，那麼咱們就沒法及時發現問題，及早預防，及早處理，只能等到出現大量的服務熔斷降級後才知道問題，而後就是漫漫排查路。這樣顯然是不行的，故有了Hystrix Dashboard組件爲咱們解決這個監控的問題。集成Hystrix Dashboard很簡單，咱們在第一節服務消費者項目的基礎上按照以下步驟操做，便可實現：

　　2.1.在POM XML中添加Hystrix Dashboard依賴、actuator依賴，具體以下：

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

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

　　2.2.在spring boot啓動類上再添加：@EnableHystrixDashboard註解，而後添加註冊HystrixMetricsStreamServlet的方法（servletRegistrationBean）,並指定映射URL爲：/actuator/hystrix.stream，若是不指定就會致使報：Unable to connect to Command Metric Stream，由於http://hystrix-app:port/actuator/hystrix.stream沒法訪問404，代碼以下：（注意這裏面同時包含了使用：ribbon、FeignClient兩種消費方式）

package cn.zuowenjun.cloud;

import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@EnableHystrixDashboard
@EnableHystrix
@EnableDiscoveryClient
@SpringBootApplication
@EnableFeignClients(basePackages = "cn.zuowenjun.cloud.service") // 若是啓動類不在根目錄須要指定basePackages，不然不須要
class EurekaclientconsumerApplication {

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

    @LoadBalanced
    @Bean
    public RestTemplate restTemplate(){
        return  new RestTemplate();
    }


    @Bean(name = "hystrixRegistrationBean")
    public ServletRegistrationBean servletRegistrationBean() {
        ServletRegistrationBean registration = new ServletRegistrationBean(
                new HystrixMetricsStreamServlet(), "/actuator/hystrix.stream");
        registration.setName("HystrixMetricsStreamServlet");
        registration.setLoadOnStartup(1);
        return registration;
    }

}

完成上述2步後，從新啓動項目，而後訪問：http://localhost:8666/hystrix，出現以下畫面即爲成功：

咱們按照提示（查看單個服務項目），輸入：http://localhost:8666/actuator/hystrix.stream，而後點擊Monitor Stream按鈕，便可進入監控查看界面，剛進行可能沒有數據只是loading...，當經過ribbon、FeignClient兩種方式進行服務消費後（即：請求遠程服務API），則監控面板的數據會實時更新，效果以下圖示：(至於具體參數各表明什麼意思請上網查看相關資料，有不少介紹的)

2.3.除了在服務消費者項目中集成Hystrix Dashboard外，若是咱們須要專門搞一個項目來查看各個服務消者，是否能夠單獨搭建呢？答案是確定的，咱們能夠搭建一個專門用於查詢每一個項目監控數據的項目（直接使用spring initializer，而後只添加eureka client、Hystrix Dashboard便可），而後仍然按照搭建服務消費者的方式添加相關依賴，但不須要編寫服務消費代碼（好比：上文中的HelloService,HelloRemoteService），由於咱們只須要保證可以與註冊中心、服務提供者通信並開啓Hystrix Dashboard便可。我這裏就作了一個演示DEMO，完整依賴以下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>cn.zuowenjun.cloud</groupId>
    <artifactId>hystrixdashboard</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>hystrixdashboard</name>
    <url>http://www.zuowenjun.cn</url>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Greenwich.RELEASE</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</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>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </repository>
    </repositories>

</project>

View Code

而後在spring boot啓動類添加以下代碼：

package cn.zuowenjun.cloud.dashboard;

import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.context.annotation.Bean;


@EnableHystrixDashboard
//@EnableDiscoveryClient
@SpringBootApplication
public class HystrixdashboardApplication {

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


    @Bean(name = "hystrixRegistrationBean")
    public ServletRegistrationBean servletRegistrationBean() {
        ServletRegistrationBean registration = new ServletRegistrationBean(
                new HystrixMetricsStreamServlet(), "/actuator/hystrix.stream");
        registration.setName("hystrixServlet");
        registration.setLoadOnStartup(1);
        return registration;
    }

}

View Code

最後在application.yml添加以下配置便可：

server:
  port: 8999

spring:
  application:
    name: hystrixdashboard

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8800/eureka/ #指向eureka server


feign:
  hystrix:
    enabled: true #啓用hystrix

View Code

訪問：http://localhost:8999/hystrix，熟悉的界面又出來了，這時就能夠輸入其它某個服務消費者的項目：http://localhost:8666/actuator/hystrix.stream，點擊Monitor Stream按鈕便可正常查看監控。這裏就不在貼圖了。

3、經過引入Turbine聚合熔斷監控數據以便統一集中查看

在這裏我基於上面2.3單獨搭建的監控面板項目（hystrixdashboard）基礎上按以下簡單的幾個步驟，即完成聚合熔斷監控數據了。

3.1.在POM XML添加以下turbine依賴：

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

3.2 在spring boot啓動類上標註@EnableTurbine，並再添加註冊HystrixMetricsStreamServlet的方法（如：servletTurbineRegistrationBean），這裏映射URL爲：/turbine.stream

package cn.zuowenjun.cloud.dashboard;

import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.netflix.turbine.EnableTurbine;
import org.springframework.context.annotation.Bean;


@EnableHystrixDashboard
@EnableDiscoveryClient
@EnableTurbine
@SpringBootApplication
public class HystrixdashboardApplication {

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


    @Bean(name = "hystrixRegistrationBean")
    public ServletRegistrationBean servletRegistrationBean() {
        ServletRegistrationBean registration = new ServletRegistrationBean(
                new HystrixMetricsStreamServlet(), "/actuator/hystrix.stream");
        registration.setName("hystrixServlet");
        registration.setLoadOnStartup(1);
        return registration;
    }

    @Bean(name = "hystrixForTurbineRegistrationBean")
    public ServletRegistrationBean servletTurbineRegistrationBean() {
        ServletRegistrationBean registration = new ServletRegistrationBean(
                new HystrixMetricsStreamServlet(), "/turbine.stream");
        registration.setName("hystrixForTurbineServlet");
        registration.setLoadOnStartup(1);
        return registration;
    }

}

3.3.在application.yml配置中增長turbine相關的參數設置，以下：（注意我這裏是監控服務消費者【他自己也是一個服務】，若是想監控全部的服務，包含服務提供者，那麼這些項目都應該集成Hystrix Dashboard，並確保http://服務主機名:端口/actuator/hystrix.stream可正常訪問，由於turbine是經過註冊中心收集全部服務的hystrix.stream的數據）

server:
  port: 8999

spring:
  application:
    name: hystrixdashboard

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8800/eureka/ #指向eureka server


turbine:
  app-config: ribbonclient #指定須要監控的服務：ribbonclient，多個service以,間隔（注意監控的服務必須要先集成Hystrix Dashboard）
  cluster-name-expression: new String("default") #指定集羣名稱，默認爲default，當設立了多個集羣時，能夠在Hystrix指定集羣名稱來查看監控
  combine-host-port: true #合併同一個host多個端口的數據

完成上面3個步驟後即OK，啓動項目，而後訪問：http://localhost:8999/hystrix，若是配置OK就又出現監控主界面，而後這裏根據提示輸入集羣的監控查詢URL，如：http://localhost:8999/turbine.stream，而後點擊Monitor Stream按鈕便可正常查看集羣中各服務的監控實時數據了。這裏就不在貼圖了。

好了本文就總結到這裏，如有不足之處歡迎指出，謝謝！

提示：本文中相關示例項目代碼已上傳GITHUB，地址以下：

https://github.com/zuowj/learning-demos/tree/master/java/demo-eurekaclientconsumer

https://github.com/zuowj/learning-demos/tree/master/java/demo-hystrixdashboard