一. 簡介
上一篇文章我們已經實現了對單個服務實例的監控，當然在實際應用中，單個實例的監控數據沒有多大的價值，我們更需要的是一個集群系統的監控信息，這時我們就需要引入turbine。turbine能夠匯集監控信息，并將聚合后的信息提供給hystrix dashboard來集中展示和監控。
二. 構建監控局和服務
2.1 整體結構與準備
本文的工程實現是基于上一篇文章的工程，通過引入turbine來聚合service-ribbon服務的監控信息，并輸出給hystrix dashboard來進行展示。因為我們需要多個服務的dashboard，所以我們將構建service-ribbon集群，同時需要新建一個service-turbine工程，用于聚合信息并展示。最終整體架構如下：
2.2 創建service-turbine
新建一個spring boot工程，命名為service-turbine，在pom.xml中導入必要的依賴：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
<?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注解，即已開啟了注冊服務：
|
1
2
3
4
5
6
7
8
|
@springbootapplication@enableturbinepublic class serviceturbineapplication { public static void main(string[] args) { springapplication.run(serviceturbineapplication.class, args); } } |
在application.properties中加入eureka和turbine的相關配置，具體如下：
|
1
2
3
4
5
6
7
8
9
10
|
spring.application.name=service-turbine server.port=8766security.basic.enabled=false eureka.client.serviceurl.defaultzone=http://localhost:8761/eureka turbine.aggregator.cluster-config=defaultturbine.app-config=service-ribbon turbine.cluster-name-expression="default"turbine.combine-host-port=true |
上面的配置中，turbine.app-config參數配置eureka中的serviceid列表，表明監控哪些服務；turbine.cluster-name-expression參數指定了集群名稱為default，當服務數量非常多的時候，可以啟動多個turbine服務來構建不同的聚合集群，而該參數可以用來區分這些不同的聚合集群，同時該參數值可以再hystrix儀表盤中用來定位不同的聚合集群，只需在hystrix stream的url中通過cluster參數來指定；turbine.combine-host-port參數設置為true，可以讓同一主機上的服務通過主機名與端口號的組合來進行區分，默認情況下會以host來區分不同的服務，這會使得在本機調試的時候，本機上的不同服務聚合成一個服務來統計。
三. 集群監控
啟動eureka-server工程，端口號為8761；
啟動eureka-client工程，端口號為8762和8763；
啟動service-ribbon工程，端口號為8764和8765；
啟動service-turbine工程，端口號為8766。
訪問http://localhost:8766/turbine.stream看到：
訪問http://localhost:8765/hystrix，輸入監控流http://localhost:8766/turbine.stream看到：
在圖中可以看到，雖然我們啟動了兩個service-ribbon，但是監控頁面中依然只是展示了一個監控圖。不過我們可以發現，圖中集群報告區域中的hosts屬性與之前嘗試單機監控時已有不同，只是因為這兩個實例是同一個服務，而對于集群來說我們關注的是服務集群的高可用性，所以turbine會將相同服務作為整體來看待，并匯總成一個監控圖。
當然啦，如果你真想看到兩個監控圖，可以把service-ribbon其中的一個實例的spring.application.name設置成別的名稱，這樣運行起來后就會出現兩個不同的監控圖。
四. 與消息代理結合
spring cloud在封裝turbine的時候，還封裝了基于消息代理的收集實現。所以，我們可以將所有需要收集的監控信息都輸出到消息代理中，然后turbine服務再從消息代理中異步獲取這些監控信息，最后將這些監控信息聚合并輸出到hystrix dashboard中。通過引入消息代理，我們的turbine和hystrix dashboard實現的監控架構可以改成如下圖所示的結構：
首先新建一個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。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
<?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的配置：
|
1
2
3
4
5
6
7
8
9
|
@springbootapplication@enableturbinestream@enablediscoveryclientpublic class serviceturbineamqpapplication { public static void main(string[] args) { springapplication.run(serviceturbineamqpapplication.class, args); } } |
接著配置application.properties文件：
|
1
2
3
|
spring.application.name=service-turbine-amqp server.port=8766eureka.client.serviceurl.defaultzone=http://localhost:8761/eureka |
對于turbine的配置已經完成了，下面需要對service-ribbon做一些修改，使其監控信息能夠輸出到rabbitmq上。這個修改也非常簡單，只需在pom.xml中增加對spring-cloud-netflix-hystrix-amqp的依賴，具體如下：
|
1
2
3
4
|
<dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-netflix-hystrix-amqp</artifactid> </dependency> |
完成上面的配置后，同樣啟動所有需要的工程，同樣訪問http://localhost:8765/hystrix，輸入監控流http://localhost:8766/turbine.stream，我們可以看到跟之前同樣的結果，只是這里的監控信息收集是通過消息代理異步實現的。
源碼下載：https://github.com/lingd3/springcloudlearning/tree/master/chapter8
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://blog.csdn.net/qwssd/article/details/79129069
