欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2024-02-10 11:18:40
一. 简介 上一篇文章我们已经实现了对单个服务实例的监控,当然在实际应用中,单个实例的监控数据没有多大的价值,我们更需要的是一个集群系统的监控信息,这时我们就需要引入tu...

一. 简介

上一篇文章我们已经实现了对单个服务实例的监控,当然在实际应用中,单个实例的监控数据没有多大的价值,我们更需要的是一个集群系统的监控信息,这时我们就需要引入turbine。turbine能够汇集监控信息,并将聚合后的信息提供给hystrix dashboard来集中展示和监控。

二. 构建监控局和服务

2.1 整体结构与准备

本文的工程实现是基于上一篇文章的工程,通过引入turbine来聚合service-ribbon服务的监控信息,并输出给hystrix dashboard来进行展示。因为我们需要多个服务的dashboard,所以我们将构建service-ribbon集群,同时需要新建一个service-turbine工程,用于聚合信息并展示。最终整体架构如下:

详解Spring Cloud 断路器集群监控(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看到:

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

访问http://localhost:8765/hystrix,输入监控流http://localhost:8766/turbine.stream看到:

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

在图中可以看到,虽然我们启动了两个service-ribbon,但是监控页面中依然只是展示了一个监控图。不过我们可以发现,图中集群报告区域中的hosts属性与之前尝试单机监控时已有不同,只是因为这两个实例是同一个服务,而对于集群来说我们关注的是服务集群的高可用性,所以turbine会将相同服务作为整体来看待,并汇总成一个监控图。

当然啦,如果你真想看到两个监控图,可以把service-ribbon其中的一个实例的spring.application.name设置成别的名称,这样运行起来后就会出现两个不同的监控图。

四. 与消息代理结合

spring cloud在封装turbine的时候,还封装了基于消息代理的收集实现。所以,我们可以将所有需要收集的监控信息都输出到消息代理中,然后turbine服务再从消息代理中异步获取这些监控信息,最后将这些监控信息聚合并输出到hystrix dashboard中。通过引入消息代理,我们的turbine和hystrix dashboard实现的监控架构可以改成如下图所示的结构:

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

首先新建一个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,我们可以看到跟之前同样的结果,只是这里的监控信息收集是通过消息代理异步实现的。

源码下载:https://github.com/lingd3/springcloudlearning/tree/master/chapter8

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。