使用Turbine聚合Hystrix监控数据

Hystrix Dashboard只能监控单个实例节点，如果要监控集群下hystrix的metrics情况，则需要借助Hystrix Turbine。Hystrix Turbine将每个服务的Hystrix监控数据进行了整合。

Turbine是Netflix提供的一个开源项目，用来提供把多个hystrix.stream的内容聚合为一个数据源供Dashboard展示。Turbine有一个重要的功能就是汇聚监控信息，并将汇聚到的监控信息提供给Hystrix Dashboard来集中展示和监控。

创建一个新的工程hystrix-turbine

    pom.xml文件关键配置：

<parent>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-parent</artifactId>
	<version>2.0.7.RELEASE</version>
	<relativePath/>
</parent>

<properties>
	<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
	<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
	<java.version>1.8</java.version>
</properties>

<dependencies>
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-netflix-turbine</artifactId>
	</dependency>
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-actuator</artifactId>
	</dependency>
</dependencies>

<dependencyManagement>
	<dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-dependencies</artifactId>
			<version>Finchley.RELEASE</version>
			<type>pom</type>
			<scope>import</scope>
		</dependency>
	</dependencies>
</dependencyManagement>

    application.properties文件：

spring.application.name=hystrix-turbine
server.port=5001

eureka.instance.hostname=${spring.cloud.client.ip-address}
eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}
eureka.instance.prefer-ip-address=true

#注册中心地址
eureka.client.service-url.defaultZone=http://root:123456@${eureka.instance.hostname}:7001/eureka/

#需要监控的服务名，多个名称用逗号分隔
turbine.app-config=service-consumer-3,service-consumer-2

#聚合的集群名称
turbine.aggregator.cluster-config=default

#集群名
turbine.cluster-name-expression=new String("default")

#设置为true，让同一主机上的服务通过主机名与端口号的组合来进行区分，默认情况下会以host来区分不同的服务。
turbine.combine-host-port=true

#turbine实例URL的后缀
turbine.instanceUrlSuffix=hystrix.stream

    启动类：

        主要是引入@EnableTurbine注解

@SpringBootApplication
@EnableTurbine //开启Turbine
public class Main {
	public static void main(String[] args) {
		SpringApplication.run(Main.class, args);
	}
}

    浏览器访问 http://localhost:5001/turbine.stream 即可查看监控数据

    在Hystrix Dashboard主界面上输入turbine的监控地址http://localhost:5001/turbine.stream，点击“Monitor Stream”按钮进行实时监控。

    微服务各个节点的关系如下图所示：