詳解Spring Cloud 斷路器集群監(jiān)控(Turbine)
一. 簡(jiǎn)介
上一篇文章我們已經(jīng)實(shí)現(xiàn)了對(duì)單個(gè)服務(wù)實(shí)例的監(jiān)控，當(dāng)然在實(shí)際應(yīng)用中，單個(gè)實(shí)例的監(jiān)控?cái)?shù)據(jù)沒有多大的價(jià)值，我們更需要的是一個(gè)集群系統(tǒng)的監(jiān)控信息，這時(shí)我們就需要引入Turbine。Turbine能夠匯集監(jiān)控信息，并將聚合后的信息提供給Hystrix Dashboard來集中展示和監(jiān)控。
二. 構(gòu)建監(jiān)控局和服務(wù)
2.1 整體結(jié)構(gòu)與準(zhǔn)備
本文的工程實(shí)現(xiàn)是基于上一篇文章的工程，通過引入Turbine來聚合service-ribbon服務(wù)的監(jiān)控信息，并輸出給Hystrix Dashboard來進(jìn)行展示。因?yàn)槲覀冃枰鄠€(gè)服務(wù)的Dashboard，所以我們將構(gòu)建service-ribbon集群，同時(shí)需要新建一個(gè)service-turbine工程，用于聚合信息并展示。最終整體架構(gòu)如下：
2.2 創(chuàng)建service-turbine
新建一個(gè)Spring Boot工程，命名為service-turbine，在pom.xml中導(dǎo)入必要的依賴：
<?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>
在工程啟動(dòng)類上加上@EnableTurbine注解，開啟Turbine，該注解已經(jīng)包含了@EnableDiscoveryClient注解，即已開啟了注冊(cè)服務(wù)：
@SpringBootApplication
@EnableTurbine
public class ServiceTurbineApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceTurbineApplication.class, args);
}
}
在application.properties中加入Eureka和Turbine的相關(guān)配置，具體如下：
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參數(shù)配置Eureka中的serviceId列表，表明監(jiān)控哪些服務(wù)；turbine.cluster-name-expression參數(shù)指定了集群名稱為default，當(dāng)服務(wù)數(shù)量非常多的時(shí)候，可以啟動(dòng)多個(gè)Turbine服務(wù)來構(gòu)建不同的聚合集群，而該參數(shù)可以用來區(qū)分這些不同的聚合集群，同時(shí)該參數(shù)值可以再Hystrix儀表盤中用來定位不同的聚合集群，只需在Hystrix Stream的URL中通過cluster參數(shù)來指定；turbine.combine-host-port參數(shù)設(shè)置為true，可以讓同一主機(jī)上的服務(wù)通過主機(jī)名與端口號(hào)的組合來進(jìn)行區(qū)分，默認(rèn)情況下會(huì)以host來區(qū)分不同的服務(wù)，這會(huì)使得在本機(jī)調(diào)試的時(shí)候，本機(jī)上的不同服務(wù)聚合成一個(gè)服務(wù)來統(tǒng)計(jì)。
三. 集群監(jiān)控
啟動(dòng)eureka-server工程，端口號(hào)為8761；
啟動(dòng)eureka-client工程，端口號(hào)為8762和8763；
啟動(dòng)service-ribbon工程，端口號(hào)為8764和8765；
啟動(dòng)service-turbine工程，端口號(hào)為8766。
訪問http://localhost:8766/turbine.stream看到：
訪問http://localhost:8765/hystrix，輸入監(jiān)控流http://localhost:8766/turbine.stream看到：
在圖中可以看到，雖然我們啟動(dòng)了兩個(gè)service-ribbon，但是監(jiān)控頁面中依然只是展示了一個(gè)監(jiān)控圖。不過我們可以發(fā)現(xiàn)，圖中集群報(bào)告區(qū)域中的Hosts屬性與之前嘗試單機(jī)監(jiān)控時(shí)已有不同，只是因?yàn)檫@兩個(gè)實(shí)例是同一個(gè)服務(wù)，而對(duì)于集群來說我們關(guān)注的是服務(wù)集群的高可用性，所以Turbine會(huì)將相同服務(wù)作為整體來看待，并匯總成一個(gè)監(jiān)控圖。
當(dāng)然啦，如果你真想看到兩個(gè)監(jiān)控圖，可以把service-ribbon其中的一個(gè)實(shí)例的spring.application.name設(shè)置成別的名稱，這樣運(yùn)行起來后就會(huì)出現(xiàn)兩個(gè)不同的監(jiān)控圖。
四. 與消息代理結(jié)合
Spring Cloud在封裝Turbine的時(shí)候，還封裝了基于消息代理的收集實(shí)現(xiàn)。所以，我們可以將所有需要收集的監(jiān)控信息都輸出到消息代理中，然后Turbine服務(wù)再從消息代理中異步獲取這些監(jiān)控信息，最后將這些監(jiān)控信息聚合并輸出到Hystrix Dashboard中。通過引入消息代理，我們的Turbine和Hystrix Dashboard實(shí)現(xiàn)的監(jiān)控架構(gòu)可以改成如下圖所示的結(jié)構(gòu)：
首先新建一個(gè)Spring Boot工程，命名為service-turbine-amqp，引入spring-cloud-starter-turbine-amqp和spring-boot-starter-actuator依賴?？吹竭@里只是引入這兩個(gè)依賴，因?yàn)閟pring-cloud-starter-turbine-amqp實(shí)際上包裝了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
對(duì)于Turbine的配置已經(jīng)完成了，下面需要對(duì)service-ribbon做一些修改，使其監(jiān)控信息能夠輸出到RabbitMQ上。這個(gè)修改也非常簡(jiǎn)單，只需在pom.xml中增加對(duì)spring-cloud-netflix-hystrix-amqp的依賴，具體如下：
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-netflix-hystrix-amqp</artifactId> </dependency>
完成上面的配置后，同樣啟動(dòng)所有需要的工程，同樣訪問http://localhost:8765/hystrix，輸入監(jiān)控流http://localhost:8766/turbine.stream，我們可以看到跟之前同樣的結(jié)果，只是這里的監(jiān)控信息收集是通過消息代理異步實(shí)現(xiàn)的。
源碼下載：https://github.com/lingd3/SpringCloudLearning/tree/master/chapter8
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
- SpringCloud之監(jiān)控?cái)?shù)據(jù)聚合Turbine的實(shí)現(xiàn)
- springcloud 熔斷監(jiān)控Hystrix Dashboard和Turbine
- 微服務(wù)搭建集成Spring Cloud Turbine詳解
- spring cloud 的監(jiān)控turbine-rabbitmq的示例
- Spring Cloud之服務(wù)監(jiān)控turbine的示例
- SpringCloud Feign參數(shù)問題及解決方法
- Spring Cloud Sleuth整合zipkin過程解析
- SpringCloud Gateway跨域配置代碼實(shí)例
- SpringCloud turbine監(jiān)控實(shí)現(xiàn)過程解析
相關(guān)文章
一個(gè)簡(jiǎn)易的Java多頁面隊(duì)列爬蟲程序
這篇文章主要為大家詳細(xì)介紹了一個(gè)多頁面的java爬蟲，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-08-08
這篇文章主要介紹了詳解Java 連接MongoDB集群的幾種方式，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-12-12
關(guān)于使用Mybatisplus自帶的selectById和insert方法時(shí)的一些問題
這篇文章主要介紹了關(guān)于使用Mybatisplus自帶的selectById和insert方法時(shí)的一些問題,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-08-08
這篇文章主要給大家介紹了關(guān)于Springboot全局異常處理的資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用SpringBoot具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2021-11-11
java SpringBoot自定義注解,及自定義解析器實(shí)現(xiàn)對(duì)象自動(dòng)注入操作
這篇文章主要介紹了java SpringBoot自定義注解,及自定義解析器實(shí)現(xiàn)對(duì)象自動(dòng)注入操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-08-08
Java如何使用itext向PDF插入數(shù)據(jù)和圖片
最近項(xiàng)目中使用到Java實(shí)現(xiàn)寫入PDF文件,這篇文章主要給大家介紹了關(guān)于Java如何使用itext向PDF插入數(shù)據(jù)和圖片的相關(guān)資料,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2024-01-01
SpringSecurity實(shí)現(xiàn)自定義登錄方式
本文介紹自定義登錄流程,包括自定義AuthenticationToken、AuthenticationFilter、AuthenticationProvider以及SecurityConfig配置類,詳細(xì)解析了認(rèn)證流程的實(shí)現(xiàn),為開發(fā)人員提供了具體的實(shí)施指導(dǎo)和參考2024-09-09
Java基于正則表達(dá)式實(shí)現(xiàn)xml文件的解析功能詳解
這篇文章主要介紹了Java基于正則表達(dá)式實(shí)現(xiàn)xml文件的解析功能,結(jié)合實(shí)例形式分析了java使用正則表達(dá)式針對(duì)xml文件節(jié)點(diǎn)的相關(guān)操作技巧,需要的朋友可以參考下2017-08-08
異常就是不正常，比如當(dāng)我們身體出現(xiàn)了異常我們會(huì)根據(jù)身體情況選擇喝開水、吃藥、看病、等?異常處理方法。?java異常處理機(jī)制是我們java語言使用異常處理機(jī)制為程序提供了錯(cuò)誤處理的能力，程序出現(xiàn)的錯(cuò)誤，程序可以安全的退出，以保證程序正常的運(yùn)行等2022-07-07
Java如何使用Iterator迭代器刪除集合重復(fù)選項(xiàng)
這篇文章主要介紹了Java如何使用Iterator迭代器刪除集合重復(fù)選項(xiàng),文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-02-02