Spring Cloud断路器集群监控的示例分析

小编给大家分享一下Spring Cloud断路器集群监控的示例分析，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

一. 简介

在实际应用中，单个实例的监控数据没有多大的价值，我们更需要的是一个集群系统的监控信息，这时我们就需要引入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  @EnableDiscoveryClient  public class ServiceTurbineAmqpApplication {      public static void main(String[] args) {      SpringApplication.run(ServiceTurbineAmqpApplication.class, args);    }  }

接着配置application.properties文件：

spring.application.name=service-turbine-amqp  server.port=8766  eureka.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，我们可以看到跟之前同样的结果，只是这里的监控信息收集是通过消息代理异步实现的。

以上是“Spring Cloud断路器集群监控的示例分析”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注亿速云行业资讯频道！