1. 簡介

Turbine (provided by the Spring Cloud Netflix project), aggregates multiple instances Hystrix metrics streams, so the dashboard can display an aggregate view. Turbine uses the DiscoveryClient interface to lookup relevant instances.

Hystrix是Netflix解決自己業務不穩定性的一個限流容錯框架，可以幫助我們解決微服務架構體系中的限流、降級、熔斷等功能。提高系統穩定性，提供了完善的監控實現，並且Hystrix可以根據監控資料動態調整內部處理機制。

Hystrix Dashboard提供了數字與圖形化的呼叫監控情況。結合Turbine可實現多Hystrix例項監控整合。

2. 程式碼實現

2.1 涉及的模組及整體步驟

2.1.1 涉及的模組

• eureka-server-singleton：微服務的服務註冊中心，限流熔斷針對的是服務呼叫異常的處理。
• eureka-hystrix-dashboard
• eureka-hystrix-dashboard-another
• eureka-hystrix-dashboard-turbine：圖形化展示資料監控情況

2.1.2 整體步驟

2. 實現eureka-server-singleton
3. 實現eureka-hystrix-dashboard
4. 實現eureka-hystrix-dashboard-another
5. 實現eureka-hystrix-dashboard-turbine
6. 呼叫eureka-hystrix-dashboard與eureka-hystrix-dashboard-another提供的服務介面
7. 開啟eureka-hystrix-dashboard-turbine的監控介面，輸入相關資訊，檢視呼叫情況

2.2 原始碼

2.2.1 Github地址

2.3 eureka-server-singleton

2.4 eureka-hystrix-dashboard

2.4 eureka-hystrix-dashboard-another

2.4.1 整體實現

1. pom.xml：引入相關依賴，具體檢視下方具體程式碼
2. application.yml：指定埠，應用名，註冊中心訪問地址資訊
3. bootstrap.yml：指定公開SpringBoot的actuator監控端點為所有
4. EurekaHystrixDashboardApplication：Spring boot啟動類，提供一個簡單的REST服務介面

2.4.2 pom.xml

<?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">
    <parent>
        <artifactId>spring-cloud-finchley-demo</artifactId>
        <groupId>org.oscar.scd</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>eureka-hystrix-dashboard-another</artifactId>

    <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>

        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-hystrix-dashboard -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
            <version>1.4.5.RELEASE</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-hystrix -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
            <version>1.4.5.RELEASE</version>
        </dependency>
    </dependencies>
</project>

2.4.3 application.yml

server:
  port: 8786

spring:
  application:
    name: eureka-hystrix-dashboard-another

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

2.4.4 bootstrap.yml

management:
  endpoints:
    web:
      exposure:
        include: '*'

2.4.5 EurekaHystrixDashboardAnotherApplication

package org.oscar.scd.eureka.hystrix.dashboard.another;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Value;
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.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@EnableHystrix
@RestController
@EnableEurekaClient
@EnableCircuitBreaker
@EnableDiscoveryClient
@SpringBootApplication
@EnableHystrixDashboard
public class EurekaHystrixDashboardAnotherApplication {

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

    @Value("${spring.application.name}")
    private String appName;

    @RequestMapping("/appName")
    @HystrixCommand(fallbackMethod = "errorMsg")
    public String getAppName() {
        return this.appName;
    }

    @SuppressWarnings("unused")
    public String errorMsg() {
        return "Error msg by hystrix.";
    }
}

2.4 eureka-hystrix-dashboard-turbine

2.4.1 整體實現

1. pom.xml：引入相關依賴，具體檢視下方具體程式碼
2. application.yml：指定埠，應用名，註冊中心訪問地址資訊
3. EurekaHystrixDashboardTurbineApplication：Spring boot啟動類，使用註解開啟Hystrix Turbine監控

2.4.2 pom.xml

<?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">
    <parent>
        <artifactId>spring-cloud-finchley-demo</artifactId>
        <groupId>org.oscar.scd</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>eureka-hystrix-dashboard-turbine</artifactId>

    <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>

        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-hystrix-dashboard -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
            <version>1.4.5.RELEASE</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-hystrix -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-hystrix</artifactId>
            <version>1.4.5.RELEASE</version>
        </dependency>

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

2.4.3 application.yml

server:
  port: 8787
spring:
  application:
    name: eureka-hystrix-dashboard-turbine
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

management:
  endpoints:
    web:
      exposure:
        include: "*"
      cors:
        allowed-origins: "*"
        allowed-methods: "*"

turbine:
  app-config: eureka-hystrix-dashboard-another,eureka-hystrix-dashboard
  aggregator:
    clusterConfig: default
  clusterNameExpression: new String("default")
  combine-host: true
  instanceUrlSuffix:
    default: actuator/hystrix.stream

2.4.4 EurekaHystrixDashboardApplication

package org.oscar.scd.eureka.hystrix.dashboard.turbine;

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.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.netflix.turbine.EnableTurbine;
import org.springframework.web.bind.annotation.RestController;

@EnableHystrix
@EnableTurbine
@RestController
@EnableEurekaClient
@EnableCircuitBreaker
@EnableDiscoveryClient
@SpringBootApplication
@EnableHystrixDashboard
public class EurekaHystrixDashboardTurbineApplication {

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

}

3. 驗證

3.1 建立SpringBoot啟動類

最簡單的方式新增一個SpringBoot啟動型別的啟動類就行，如果對SpringBoot有所瞭解或者看過前面系列的文章，這裡很簡單。

3.1.1 EurekaServerSingletonApplication

略

3.1.2 EurekaHystrixDashboardApplication

略

3.1.2 EurekaHystrixDashboardAnotherApplication

略

3.1.2 EurekaHystrixDashboardTurbineApplication

略

3.2 啟動

1. EurekaServerSingletonApplication
2. EurekaHystrixDashboardApplication
3. EurekaHystrixDashboardAnotherApplication
4. EurekaHystrixDashboardTurbineApplication

3.3 檢視Hystrix Dashboard

eureka-hystrix-dashboard

eureka-hystrix-dashboard-another

4. 訪問http://localhost:8787/hystrixHystrix介面前兩個輸入框依次輸入：http://localhost:8787/turbine.stream、2000。注意是8787埠的turbine.stream，如果沒有資料，多呼叫幾次服務埠
   

4. 思考

• 如何與呼叫鏈監控整合，也就是如何搭建一個完整的監控平臺
• 現在這個要輸入查詢條件，如何定製化首介面和展示項，更接近於實用和生產
• 監控項或者監控資訊是否可定製化，Spring Boot的actuator如何使用的，具體有哪些endpoint。

5. 補充

5.1 資料