您好,登錄后才能下訂單哦!
1.概述
本文中,我將向你介紹Spring Cloud Netflix Turbine。它將多個(gè)Hystrix Metrics Streams 聚合為一個(gè),以便顯示在一個(gè)儀表板視圖中。
簡(jiǎn)要介紹Hystrix 。 在微服務(wù)架構(gòu)中,我們有許多小應(yīng)用程序相互通信以完成請(qǐng)求。這些下游服務(wù)有可能無(wú)法正確響應(yīng)或完全失敗。為了防止發(fā)生級(jí)聯(lián)故障,我們?yōu)槲⒎?wù)設(shè)置了Hystrix回退機(jī)制。
每個(gè)實(shí)現(xiàn)Hystrix的微服務(wù)都可以選擇公開(kāi)Hystrix Metrics Streams(通過(guò)actuator端點(diǎn)/hystrix.stream),以便通過(guò)Hystrix Dashboard查看。
如果您想了解更多信息,我已在Spring Cloud:Hystrix中詳細(xì)介紹了這一點(diǎn)。
Turbine是Netflix的一個(gè)開(kāi)源工具,用于將多個(gè)流聚合到一個(gè)流中。 Spring提供了一個(gè)很好的包裝器,以方便在Spring生態(tài)系統(tǒng)中使用。
2.搭建
類似于Spring Cloud:Hystrix的設(shè)置,后端服務(wù)如下所示:
以下是我們?cè)贓ureka服務(wù)器上看到的服務(wù)列表:
user-service和recommendation-service都實(shí)現(xiàn)了Hystrix回退機(jī)制,并通過(guò)Actuator暴露了/hystrix.stream端點(diǎn):
我們可以在Hystrix dashboard中單獨(dú)查看這些,方法是在框中鍵入U(xiǎn)RL并單擊Monitor Stream即可:
你將看到如下指標(biāo)(metric):
注意:如果沒(méi)有看到任何流(stream),那么可能必須點(diǎn)擊該stream的服務(wù)端點(diǎn)。 例如:對(duì)于user-service,我們可以點(diǎn)擊http://localhost:8060/personalized/1來(lái)生成流。
3.安裝Turbine
你可能已經(jīng)意識(shí)到,查看單個(gè)流(stream)的效率不高,尤其是有許多微服務(wù)時(shí)。
Turbine可以將所有單獨(dú)的hystrix.stream聚合成一個(gè)turbine.stream,以便在Hystrix Dashboard上查看。
它使用DiscoveryClient接口找出生產(chǎn)/hystrix.stream的相關(guān)服務(wù)。
要將Turbine添加到Hystrix dashboard,請(qǐng)?zhí)砑右韵乱蕾図?xiàng):
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-turbine</artifactId> </dependency>
注意:這是Turbine的starter依賴,默認(rèn)情況下使用Spring Cloud Eureka作為服務(wù)發(fā)現(xiàn)。 如果使用的是Spring Cloud Consul,請(qǐng)使用以下依賴項(xiàng):
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-netflix-turbine</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-consul-discovery</artifactId> </dependency>
在本文中,我們將使用starter依賴,即spring-cloud-starter-netflix-turbine。
要啟用Turbine,只需使用@EnableTurbine注解主類:
@SpringBootApplication @EnableTurbine @EnableDiscoveryClient @EnableHystrixDashboard public class HystrixTurbineApplication { public static void main(String[] args) { SpringApplication.run(HystrixTurbineApplication.class, args); } }
為了使Turbine按預(yù)期工作,我們必須在application.properties中添加一些細(xì)節(jié):
server.port= 9090 spring.application.name= hystirx-turbine eureka.client.serviceUrl.defaultZone= http://localhost:8761/eureka/ turbine.appConfig= user-service,recommendation-service turbine.clusterNameExpression= new String("default")
在這里,我們告訴Turbine Eureka服務(wù)器的位置,以及它需要獲取/ hystrix.stream的應(yīng)用程序。并將turbine.clusterNameExpression設(shè)為new String("default"),即默認(rèn)集群名稱為“default”。
我們可以打開(kāi)http://localhost:9090/turbine.stream?cluster=default來(lái)查看user-service和recommendation-service的聚合流:
同樣,如果沒(méi)有查看到任何內(nèi)容,只需點(diǎn)擊user-service和recommendation-service端點(diǎn)即可生成流。
我們還可以在Hystrix dashboard上使用此URL來(lái)生成一個(gè)很好的聚合視圖:
有時(shí),您可能希望將Eureka的serviceId用作dashboard的集群名稱。這可以通過(guò)設(shè)置turbine.aggregator.clusterConfig來(lái)完成:
server.port = 9090 spring.application.name = hystirx-turbine eureka.client.serviceUrl.defaultZone = http:// localhost:8761 / eureka / turbine.aggregator.clusterConfig = USER-SERVICE,RECOMMENDATION-SERVICE turbine.appConfig =用戶服務(wù),推薦服務(wù)
您還可以通過(guò)點(diǎn)擊/clusters端點(diǎn)來(lái)檢查Turbine應(yīng)用程序中當(dāng)前已配置的集群。
可以通過(guò)將turbine.endpoints.clusters.enabled設(shè)置為false來(lái)禁用此端點(diǎn)。
所以,現(xiàn)在我們可以將turbine.stream視為Eureka ID,例如:http://localhost:9090/turbine.stream?cluster=USER-SERVICE
如果特定服務(wù)的多個(gè)實(shí)例正在運(yùn)行,Turbine將按照集群進(jìn)行分揀并將其顯示在結(jié)果中。
4.總結(jié)
在本文中,我們已經(jīng)介紹了如何在Hystrix stream的基礎(chǔ)上設(shè)置Turbine以獲得聚合視圖。我們首先看到了Turbine從所有服務(wù)中獲取Hystrix stream的經(jīng)典方法。
與往常一樣,本文中使用的示例代碼可以在GitHub上找到。
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持億速云。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。