人生,抬頭就不能看到地面,低頭就不能仰望天空。記住還記住的,忘記該忘記的,改變能改變的,接受不能改變的。何必無理智的苛求?該是你的,躲著躲不過,不是你的,求也求不來。 ...
本文是Spring Cloud專欄的第八篇文章,瞭解前七篇文章內容有助於更好的理解本文:
一、前言
《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