​

本文是Spring Cloud專欄的第八篇文章，瞭解前七篇文章內容有助於更好的理解本文：

1. Spring Cloud第一篇 | Spring Cloud前言及其常用元件介紹概覽

2. Spring Cloud第二篇 | 使用並認識Eureka註冊中心

3. Spring Cloud第三篇 | 搭建高可用Eureka註冊中心

4. Spring Cloud第四篇 | 客戶端負載均衡Ribbon

5. Spring Cloud第五篇 | 服務熔斷Hystrix

6. Spring Cloud第六篇 | Hystrix儀表盤監控Hystrix Dashboard

7. Spring Cloud第七篇 | 宣告式服務呼叫Feign

​

一、前言

    《Spring Cloud快速開發入門第六篇---Hystrix儀表盤監控Hystrix Dashboard》一文我們看了一個監控單體應用的例子，在實際應用中，我們要監控的應用往往是一個叢集，這個時候我們就得采取Turbine叢集監控了。Turbine有一個重要的功能就是匯聚監控資訊，並將匯聚到的監控資訊提供給Hystrix Dashboard來集中展示和監控。那我們就來看看Turbine叢集監控如何使用。

Turbine所處的作用如圖：

​

二、Turbine的應用

1、建立turbine模組(springcloud-hystrix-turbine)

2、新增依賴

<!--trubine相應依賴-->
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-turbine</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

3、在啟動類上添加註解

@EnableDiscoveryClient //和該註解@EnableEurekaClient功能一樣 //開啟eureka客戶端功能
@EnableTurbine //開啟turibine相關支援

4、修改application.yml

server:
  port: 2002
spring:
  application:
    name: springcloud-hystrix-turbine
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8700/eureka
    #客戶端每隔30秒從Eureka服務上更新一次服務資訊
    registry-fetch-interval-seconds: 30
    #需要將我的服務註冊到eureka上
    register-with-eureka: true
    #需要檢索服務
    fetch-registry: true
  #心跳檢測檢測與續約時間
  instance:
    #告訴服務端，如果我10s之內沒有給你發心跳，就代表我故障了，將我剔除掉，預設90s
    #Eureka服務端在收到最後一次心跳之後等待的時間上限，單位為秒，超過則剔除（客戶端告訴服務端按照此規則等待自己）
    lease-expiration-duration-in-seconds: 10
    #每隔2s向服務端傳送一次心跳，證明自已依然活著，預設30s
    #Eureka客戶端向服務端傳送心跳的時間間隔，單位為秒（客戶端告訴服務端自己會按照該規則）
    lease-renewal-interval-in-seconds: 2
    # 啟用ip配置 這樣在註冊中心列表中看見的是以ip+埠呈現的
    prefer-ip-address: true
    # 例項名稱  最後呈現地址：ip:2002
    instance-id: ${spring.cloud.client.ip-address}:${server.port}
 
turbine:
  # true 同一主機上的服務通過host和port的組合來進行區分，預設為true
  # false 以host來區分不同的服務,這會使得在本地除錯的時候,本機上的不同服務聚合成一個服務來統計，監控中host叢集數會為1了因為本地host是一樣的
  combine-host-port: true
  #turbine.app-config: 配置Euraka中的serviceId列表，表明監控哪些服務
  app-config: springcloud-service-consumer
  # 1. 省略clusterNameExpression時，此時turbine.aggregator.clusterConfig需要配置想要監控的應用名稱，需要監控應用名稱必須大寫
  # 2. 當clusterNameExpression: default時，turbine.aggregator.clusterConfig可以不寫，因為預設就是default
  # 3. 當clusterNameExpression: metadata['cluster']時，假設想要監控的應用配置了eureka.instance.metadata-map.cluster: consumer，則需要配置，同時turbine.aggregator.clusterConfig: consumer
  cluster-name-expression: new String('default')

5、在完成上面的構建之後，我們體驗下Turbine對叢集的監控能力。分別啟動註冊中心(springcloud-eureka-server)，消費者啟動兩個(springcloud-service-consumer/9090，springcloud-service-consumer/9091)，服務提供者(springcloud-service-provider)，Hystrix Dashboard(springcloud-hystrix-dashboard)，Turbine模組(springcloud-hystrix-turbine)

6、檢視註冊中心上註冊的服務為：http://localhost:8700

​

7、在 Hystrix儀表盤上輸入turbine的/turbine.stream端點，http://localhost:2002/turbine.stream

​

8、結果如下圖

​

    從圖中可以看到,雖然我們和之前的架構那樣啟動了兩個springcloud-service-consumer,但是在監控頁面中依然只是展示了一個監控圖。不過仔細的話可能已經發現,圖中叢集報告區域中的Hosts屬性與之前嘗試單機監控時已經有所不同。由此我們可以知道springcloud-service-consumer啟動了兩個例項,這裡只展現了一個監控圖,是由於這兩個例項是同一個服務,而對於叢集來說我們關注的是服務叢集的高可用性,所以Turbine會將相同服務作為整體來看待,並彙總成一個監控圖。

    我們不區分叢集的話，我們啟動很多服務都是在這個介面上看到的，都聚合到一起了，如果我們叢集很多，想要分叢集檢視，如下步驟。

三、Turbine自定義叢集監控

如果微服務數量特別多，我們想要監控某個服務叢集的狀況可以配置如下：

這次啟動消費者模組(springcloud-service-consumer/9090，springcloud-service-feign/9091)

1、我們需要修改消費者模組(springcloud-service-consumer/9090，springcloud-service-feign/9091)的application.yml

springcloud-service-consumer新增配置為：

eureka:
  instance:
    metadata-map:
      cluster: consumer

springcloud-service-feign新增配置為：

eureka:
  instance:
    metadata-map:
      cluster: feign

2、修改Turbine模組的application.yml配置如下，只列出turbine相關配置，其他配置看原始碼案例

turbine:
  # true 同一主機上的服務通過host和port的組合來進行區分，預設為true
  # false 以host來區分不同的服務,這會使得在本地除錯的時候,本機上的不同服務聚合成一個服務來統計，監控中host叢集數會為1了因為本地host是一樣的
  combine-host-port: true
  aggregator:
   #指定聚合哪些叢集, 多個使用","分割, 預設為default
   #可使用http://.../turbine.stream?cluster={clusterConfig之一}訪問
    cluster-config: consumer,feign
​
  #turbine.app-config: 配置Euraka中的serviceId列表，表明監控哪些服務
  app-config: springcloud-service-consumer,springcloud-service-feign
  # 1. 省略clusterNameExpression時，此時turbine.aggregator.clusterConfig需要配置想要監控的應用名稱，需要監控應用名稱必須大寫
  # 2. 當clusterNameExpression: default時，turbine.aggregator.clusterConfig可以不寫，因為預設就是default
  # 3. 當clusterNameExpression: metadata['cluster']時，假設想要監控的應用配置了eureka.instance.metadata-map.cluster: consumer，則需要配置，同時turbine.aggregator.clusterConfig: consumer
  #cluster-name-expression: "'default'"
  cluster-name-expression: metadata['cluster']

3、在(springcloud-service-feign/9091)模組的啟動類上必須新增@EnableCircuitBreaker註解，不然端點/actuator/hystrix.stream不會暴露出來

​

4、訪問turbine的clusters埠http://localhost:2002/clusters，檢視如圖

​

5、在hystrix Dashboard輸入turbine的地址，指定叢集，如圖：

consumer叢集：http://localhost:2002/turbine.stream?cluster=consumer

​

feign叢集：http://localhost:2002/turbine.stream?cluster=feign

​

5、我們可以看到我們指定的叢集狀況資訊

consumer叢集狀況資訊：

​

feign叢集狀況資訊：

​

這樣區分的作用是，如果專案有很多的服務，可以通過區分叢集來分別檢視

詳細參考案例原始碼：https://gitee.com/coding-farmer/spirngcloud-learn

​