- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章详解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中导入必要的依赖:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
<?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注解,即已开启了注册服务:
1
2
3
4
5
6
7
8
|
@springbootapplication
@enableturbine
public
class
serviceturbineapplication {
public
static
void
main(string[] args) {
springapplication.run(serviceturbineapplication.
class
, args);
}
}
|
在application.properties中加入eureka和turbine的相关配置,具体如下:
1
2
3
4
5
6
7
8
9
10
|
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.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
<?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的配置:
1
2
3
4
5
6
7
8
9
|
@springbootapplication
@enableturbinestream
@enablediscoveryclient
public
class
serviceturbineamqpapplication {
public
static
void
main(string[] args) {
springapplication.run(serviceturbineamqpapplication.
class
, args);
}
}
|
接着配置application.properties文件:
1
2
3
|
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的依赖,具体如下:
1
2
3
4
|
<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的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
由于 PostgreSQL 人员选择的术语不当,这会让一些人感到困惑,但请耐心等待... 我们需要能够支持多个 PostgreSQL (PG) 集群,并将它们集群在多个服务器上,例如使用repmgr.
Hadoop会跑很多jobs,从Hbase读取数据,写数据到数据库。假设我有 100 个节点,那么有两种方法可以构建我的 Hadoop/Hbase集群: 100节点hadoop&hbase集群(1个b
在kafka中,我们能创建多种类型的集群,一般如下: 单节点——单个broker集群 单节点——多broker集群 多结点——多broker集群 kafka集群中主要有五个组件: Topic:主题主要
我想在两台机器上运行我的 MPI 程序,一台是 ubuntu 18.04,另一台是 Windows 10。是否可以使用不同的操作系统组成一个集群? (我正在使用 MPICH) 如果可能,怎么做?我在网
简介: 更新负载平衡集群中的节点的最佳实践是什么? 我们在 ha 代理负载均衡器后面使用 RabbitMQ 集群来支持我们的客户端轻松集群,as suggested in the RabbitMQ d
我正在尝试创建一个图表,我明确指定了许多节点的等级并指定了集群。以下代码生成我想要的图形类型: digraph { rankdir=LR subgraph cluster0 {
我正在尝试在 RABBITMQ 上进行集群。我添加了 2 个节点,但无法添加第 3 个节点。我已经聚集了 rabbit@node1 和 rabbit@node2。现在我正在尝试将 rabbit@nod
我在 MS Azure 的生产环境中启用了一个双集群多区域 HA。 我被要求重用同一个集群来使用微服务管理几个新项目。 这里的最佳做法是什么?我应该为每个应用程序创建一个集群吗?将不同集群中的每个项目
我正在尝试 flex 搜索,并且很难在具有3个 flex 搜索实例的单台计算机上创建集群。我对实例进行了以下更改: 在所有实例上更改了群集名称{cluster.name:es-stack} 在所有实例
我想创建一个redis集群,仅将特定的redis主机作为主服务器和从服务器。另外,我想自己指定哪个主机应该是哪个主机的副本。 目前,cluster-create command当在任何一个 Redis
我计划在具有负载平衡的集群中设置 Magento,那么是否可以让两个 Magento 安装指向同一个数据库? 如果可能的话 - 我应该如何配置这些服务器的基本 URL?服务器应该具有相同的名称吗? 最
我目前正在计划一个 Web 应用程序,我想计划它最终在集群上运行。 集群将由一个 php web 集群和一个 mysql 集群以及一个独立的存储单元组成(也许是一个集群,我真的不知道它是如何工作的:s
我已经安装了 elasticsearch 2.2.3 并在 2 个节点的集群中配置 节点 1 (elasticsearch.yml) cluster.name: my-cluster node.nam
我正在寻找现有的中间件解决方案,以解决服务集群/分布方面的问题,以实现负载平衡和可用性。我正在考虑基于消息传递系统(更具体地说,JMS)为此构建自己的基础设施。但是,如果可能的话,我宁愿使用已经存在的
在 Hadoop 集群中,数据是自动跨数据节点复制还是必须编程? 如果必须编程,那我该怎么做呢? 最佳答案 dfs.replication 的默认值为 3。这存在于您的 hdfs.site.xml 中
我已经设置了一个具有 1 个主节点和 2 个从节点的 redis 集群,哨兵在所有 3 个节点上运行。 在此设置之前,我的应用程序指向运行 Redis 实例的单个节点。 集群搭建完成后,我的应用应该指
所以,我正在设计一个具有多个 redis 实例的分布式系统来分解大量的流式写入,但发现很难清楚地了解事情是如何工作的。 从我读到的内容来看,正确配置的集群似乎会自动对“错误实例”上的请求进行分片和重定
我有一个关于redis集群架构的问题。 我正在设置一个 Redis 集群,并遵循基本建议:3 硕士3个奴隶 有什么方法可以在 Amazon LB、HAProxy、Nginx 等负载均衡器后面配置此集群
那么集群背后的想法是什么? 您有多台机器具有相同的数据库副本,您在其中传播读/写?这是正确的吗? 这个想法如何运作?当我进行选择查询时,集群会分析哪个服务器的读/写较少并将我的查询指向该服务器? 当您
目录 一.系统环境 二.前言 三.Kubernetes 3.1 概述 3.2 Kube
我是一名优秀的程序员,十分优秀!