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

本文轉載自查看原文 2019-02-23 23:05 1003 JAVA

本文內容導航目錄：

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

前言：

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

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

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

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

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

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

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

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

Tips：我們在項目中經常需要添加很多的maven依賴，依賴組件（或稱類庫）的名字可能各不相同，我們可以通過如下方式查詢相關的maven依賴包及其依賴包本身的內部依賴詳情

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

一、搭建服務消費者項目，並集成 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，資源隔離策略說明參見：https://blog.csdn.net/liuchuanhong1/article/details/73718794，有信號量、線程池兩種隔離方式，默認是線程池隔離，兩者的區別如下圖示：（圖片來源：前面給出的鏈接文章，這里重點貼出說明）

最后直接啟動運行，如訪問：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演示的降級回調結果如下圖示：

二、集成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按鈕即可正常查看監控。這里就不在貼圖了。

三、通過引入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

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 Spring Cloud 之 Hystrix 知識點：隔離、熔斷、降級 spring cloud 學習(4) - hystrix 服務熔斷處理 Spring Cloud實戰之初級入門（四）— 利用Hystrix實現服務熔斷與服務監控 Spring-Cloud 學習筆記-（5）熔斷器Hystrix Spring Cloud第五篇 | 服務熔斷Hystrix Spring Cloud Hystrix降級處理超時時間設置 SpringCloud(6)---熔斷降級理解、Hystrix實戰聊聊微服務熔斷降級Hystrix Feign + Hystrix 服務熔斷和服務降級 Hystrix介紹以及服務的降級限流熔斷