Spring Cloud ：断路器集群监控(Turbine)

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

<?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注解，即已开启了注册服务：
@SpringBootApplication
@EnableTurbine
public class ServiceTurbineApplication {

public static void main(String[] args) {
SpringApplication.run(ServiceTurbineApplication.class, args);
}
}
      在application.properties中加入Eureka和Turbine的相关配置，具体以下：
spring.application.name=service-turbine
server.port=8766
security.basic.enabled=false

eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka

turbine.aggregator.cluster-config=default
turbine.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。

<?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的配置：@SpringBootApplication@EnableTurbineStream@EnableDiscoveryClientpublic class ServiceTurbineAmqpApplication { public static void main(String[] args) { SpringApplication.run(ServiceTurbineAmqpApplication.class, args); }}      接着配置application.properties文件：spring.application.name=service-turbine-amqpserver.port=8766eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka      对于Turbine的配置已经完成了，下面须要对service-ribbon作一些修改，使其监控信息可以输出到RabbitMQ上。这个修改也很是简单，只需在pom.xml中增长对spring-cloud-netflix-hystrix-amqp的依赖，具体以下：<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-netflix-hystrix-amqp</artifactId></dependency>      完成上面的配置后，一样启动全部须要的工程，一样访问http://localhost:8765/hystrix，输入监控流http://localhost:8766/turbine.stream，咱们能够看到跟以前一样的结果，只是这里的监控信息收集是经过消息代理异步实现的。