詳解Spring Cloud 斷路器集群監(jiān)控(Turbine)

更新時間：2018年05月02日 09:49:07 作者：嵩園

這篇文章主要介紹了詳解Spring Cloud 斷路器集群監(jiān)控(Turbine)，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

一. 簡介

上一篇文章我們已經實現(xiàn)了對單個服務實例的監(jiān)控，當然在實際應用中，單個實例的監(jiān)控數(shù)據(jù)沒有多大的價值，我們更需要的是一個集群系統(tǒng)的監(jiān)控信息，這時我們就需要引入Turbine。Turbine能夠匯集監(jiān)控信息，并將聚合后的信息提供給Hystrix Dashboard來集中展示和監(jiān)控。

二. 構建監(jiān)控局和服務

2.1 整體結構與準備

本文的工程實現(xiàn)是基于上一篇文章的工程，通過引入Turbine來聚合service-ribbon服務的監(jiān)控信息，并輸出給Hystrix Dashboard來進行展示。因為我們需要多個服務的Dashboard，所以我們將構建service-ribbon集群，同時需要新建一個service-turbine工程，用于聚合信息并展示。最終整體架構如下：

2.2 創(chuàng)建service-turbine

新建一個Spring Boot工程，命名為service-turbine，在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"> 
  <modelVersion>4.0.0</modelVersion> 
 
  <groupId>com.dan</groupId> 
  <artifactId>service-turbine</artifactId> 
  <version>0.0.1-SNAPSHOT</version> 
  <packaging>jar</packaging> 
 
  <name>service-turbine</name> 
  <description>Demo project for Spring Boot</description> 
 
  <parent> 
    <groupId>org.springframework.boot</groupId> 
    <artifactId>spring-boot-starter-parent</artifactId> 
    <version>1.5.9.RELEASE</version> 
    <relativePath/> <!-- lookup parent from repository --> 
  </parent> 
 
  <properties> 
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> 
    <java.version>1.8</java.version> 
    <spring-cloud.version>Edgware.SR1</spring-cloud.version> 
  </properties> 
 
  <dependencies> 
 <dependency> 
 <groupId>org.springframework.cloud</groupId> 
 <artifactId>spring-cloud-starter-turbine</artifactId> 
 </dependency> 
 <dependency> 
 <groupId>org.springframework.cloud</groupId> 
 <artifactId>spring-cloud-netflix-turbine</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>${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> 
</project>

在工程啟動類上加上@EnableTurbine注解，開啟Turbine，該注解已經包含了@EnableDiscoveryClient注解，即已開啟了注冊服務：

@SpringBootApplication 
@EnableTurbine 
public class ServiceTurbineApplication { 
 
  public static void main(String[] args) { 
    SpringApplication.run(ServiceTurbineApplication.class, args); 
  } 
}

在application.properties中加入Eureka和Turbine的相關配置，具體如下：

spring.application.name=service-turbine 
server.port=8766 
security.basic.enabled=false 
 
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka 
 
turbine.aggregator.cluster-config=default 
turbine.app-config=service-ribbon 
turbine.cluster-name-expression="default" 
turbine.combine-host-port=true

上面的配置中，turbine.app-config參數(shù)配置Eureka中的serviceId列表，表明監(jiān)控哪些服務；turbine.cluster-name-expression參數(shù)指定了集群名稱為default，當服務數(shù)量非常多的時候，可以啟動多個Turbine服務來構建不同的聚合集群，而該參數(shù)可以用來區(qū)分這些不同的聚合集群，同時該參數(shù)值可以再Hystrix儀表盤中用來定位不同的聚合集群，只需在Hystrix Stream的URL中通過cluster參數(shù)來指定；turbine.combine-host-port參數(shù)設置為true，可以讓同一主機上的服務通過主機名與端口號的組合來進行區(qū)分，默認情況下會以host來區(qū)分不同的服務，這會使得在本機調試的時候，本機上的不同服務聚合成一個服務來統(tǒng)計。

三. 集群監(jiān)控

啟動eureka-server工程，端口號為8761；

啟動eureka-client工程，端口號為8762和8763；

啟動service-ribbon工程，端口號為8764和8765；

啟動service-turbine工程，端口號為8766。

訪問http://localhost:8766/turbine.stream看到：

訪問http://localhost:8765/hystrix，輸入監(jiān)控流http://localhost:8766/turbine.stream看到：

在圖中可以看到，雖然我們啟動了兩個service-ribbon，但是監(jiān)控頁面中依然只是展示了一個監(jiān)控圖。不過我們可以發(fā)現(xiàn)，圖中集群報告區(qū)域中的Hosts屬性與之前嘗試單機監(jiān)控時已有不同，只是因為這兩個實例是同一個服務，而對于集群來說我們關注的是服務集群的高可用性，所以Turbine會將相同服務作為整體來看待，并匯總成一個監(jiān)控圖。

當然啦，如果你真想看到兩個監(jiān)控圖，可以把service-ribbon其中的一個實例的spring.application.name設置成別的名稱，這樣運行起來后就會出現(xiàn)兩個不同的監(jiān)控圖。

四. 與消息代理結合

Spring Cloud在封裝Turbine的時候，還封裝了基于消息代理的收集實現(xiàn)。所以，我們可以將所有需要收集的監(jiān)控信息都輸出到消息代理中，然后Turbine服務再從消息代理中異步獲取這些監(jiān)控信息，最后將這些監(jiān)控信息聚合并輸出到Hystrix Dashboard中。通過引入消息代理，我們的Turbine和Hystrix Dashboard實現(xiàn)的監(jiān)控架構可以改成如下圖所示的結構：

首先新建一個Spring Boot工程，命名為service-turbine-amqp，引入spring-cloud-starter-turbine-amqp和spring-boot-starter-actuator依賴?？吹竭@里只是引入這兩個依賴，因為spring-cloud-starter-turbine-amqp實際上包裝了spring-cloud-starter-turbine-stream和spring-cloud-starter-stream-rabbit。

<?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> 
 
  <groupId>com.dan</groupId> 
  <artifactId>service-turbine-amqp</artifactId> 
  <version>0.0.1-SNAPSHOT</version> 
  <packaging>jar</packaging> 
 
  <name>service-turbine-amqp</name> 
  <description>Demo project for Spring Boot</description> 
 
  <parent> 
    <groupId>org.springframework.boot</groupId> 
    <artifactId>spring-boot-starter-parent</artifactId> 
    <version>1.5.9.RELEASE</version> 
    <relativePath/> <!-- lookup parent from repository --> 
  </parent> 
 
  <properties> 
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> 
    <java.version>1.8</java.version> 
    <spring-cloud.version>Edgware.SR1</spring-cloud.version> 
  </properties> 
 
  <dependencies> 
    <dependency> 
      <groupId>org.springframework.cloud</groupId> 
      <artifactId>spring-cloud-starter-turbine-amqp</artifactId> 
    </dependency> 
 
    <dependency>       <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-actuator</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> 
</project>

在主類中使用@EnableTurbineStream注解來啟用Turbine Stream的配置：

@SpringBootApplication 
@EnableTurbineStream 
@EnableDiscoveryClient 
public class ServiceTurbineAmqpApplication { 
 
  public static void main(String[] args) { 
    SpringApplication.run(ServiceTurbineAmqpApplication.class, args); 
  } 
}

接著配置application.properties文件：

spring.application.name=service-turbine-amqp 
server.port=8766 
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka

對于Turbine的配置已經完成了，下面需要對service-ribbon做一些修改，使其監(jiān)控信息能夠輸出到RabbitMQ上。這個修改也非常簡單，只需在pom.xml中增加對spring-cloud-netflix-hystrix-amqp的依賴，具體如下：

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

完成上面的配置后，同樣啟動所有需要的工程，同樣訪問http://localhost:8765/hystrix，輸入監(jiān)控流http://localhost:8766/turbine.stream，我們可以看到跟之前同樣的結果，只是這里的監(jiān)控信息收集是通過消息代理異步實現(xiàn)的。

源碼下載：https://github.com/lingd3/SpringCloudLearning/tree/master/chapter8

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: