一. 简介
上一篇文章我们已经实现了对单个服务实例的监控，当然在实际应用中，单个实例的监控数据没有多大的价值，我们更需要的是一个集群系统的监控信息，这时我们就需要引入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
