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

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

转载作者：qq735679552 更新时间：2022-09-27 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章详解Spring Cloud 断路器集群监控(Turbine)由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

一. 简介。

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

。

访问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 。

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

原文链接：https://blog.csdn.net/qwssd/article/details/79129069 。

最后此篇关于详解Spring Cloud 断路器集群监控(Turbine)的文章就讲到这里了,如果你想了解更多关于详解Spring Cloud 断路器集群监控(Turbine)的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐：详解Python的Flask框架中生成SECRET_KEY密钥的方法

文章推荐： Python的Flask框架中配置多个子域名的方法讲解

文章推荐： python3批量删除豆瓣分组下的好友的实现代码

文章推荐： Spring Cloud Config对特殊字符加密处理的方法详解

6、Hystrix 断路器
断路器工作原理 1、如果经过断路器的流量超过了一定的阈值，HystrixCommandProperties.circuitBreakerRequestVolumeThreshold()；举个例
java - 使用回退的 Resilience4j 断路器
关闭。这个问题需要多问focused 。目前不接受答案。想要改进此问题吗？更新问题，使其仅关注一个问题 editing this post . 已关闭 3 年前。 Improve this ques
javascript - SVG 断路器/开关合闸动画
我正在尝试设计一个断路器/开关，它可以在某些事件中关闭和打开。我使用 SVG 设计了断路器，并使用 css 动画和转换属性来为它的关闭设置动画。使用 transform-origin: bottom
hadoop - Apache Spark 断路器
在 Hadoop YARN 集群中使用 Apache Spark 1.6.2。一些(简单的)查询会消耗大量资源，我看到我们的开发人员针对 1To 文件运行 SELECT * FROM DB!因此，它
javascript - 如何优雅地处理 iframe 断路器？
我知道没有办法杀死 iframe 断路器......但是，我想知道，有没有办法优雅地处理它。到目前为止，我在退出之前设法检测到它，使用 .我想知道是否可以阻止它加载iframe或强制它在新窗口中打
java - 带有业务异常的 Hystrix 断路器
我观察到 Hystrix 将所有来自命令的异常视为断路目的的失败。它包括从 command run() 方法抛出并由 Hystrix 本身创建的异常，例如HystrixTimeoutException
详解Spring Cloud 熔断机制--断路器
断路器（curcuit breaker）模式在分布式环境下，特别是微服务结构的分布式系统中，一个软件系统调用另外一个远程系统是非常普遍的。这种远程调用的被调用方可能是另外一个进程，或者是跨网路
micronaut - 是否可以针对某些 HTTP 状态代码跳过 Micronaut 断路器？
有没有办法配置 Micronaut 断路器，使其不针对特定的 HTTP 状态代码打开？例如，如果我查找某个项目但未找到该项目，则服务器可能会返回 HTTP 状态 404。这可能是一个完全有效的响应，我
Elasticsearch 7.x 断路器 - 数据过大 - 故障排除
问题: 自从从 ES-5.4 升级到 ES-7.2 后，当我尝试从我的多线程 Java 应用程序(使用 elasticsearch-rest-high-level-client-7.2.0.jar j
spring-boot - 如何在使用 spring-boot 断路器(Hystrix)时将数据从业务方法传递到回退方法？
在官方 https://spring.io/guides/gs/circuit-breaker/手册有业务方法(阅读列表) 回退方法(可靠) @HystrixCommand(fallbackMeth
java - 如何在 Apache Camel 中结合 Redelivery 策略和 Hystrix 断路器？
我想通过重试和 Hystrix 断路器实现 Apache Camel 路由。我的路线如下所示: ...... java.lang.Exception
spring-webflux - Webflux WebClient 重试与 Spring Cloud 断路器 Resilience4J 重试模式走进一个吧
想问一个关于两种技术的问题。我们首先从一个必须调用其他第三方 rest API 的应用程序开始，因此，我们在 SpringBoot Webflux 项目中使用了 Webflux WebClient。

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

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