springcloud 熔斷監(jiān)控Hystrix Dashboard和Turbine
Hystrix-dashboard是一款針對Hystrix進行實時監(jiān)控的工具,通過Hystrix Dashboard我們可以在直觀地看到各Hystrix Command的請求響應(yīng)時間, 請求成功率等數(shù)據(jù)。但是只使用Hystrix Dashboard的話, 你只能看到單個應(yīng)用內(nèi)的服務(wù)信息, 這明顯不夠. 我們需要一個工具能讓我們匯總系統(tǒng)內(nèi)多個服務(wù)的數(shù)據(jù)并顯示到Hystrix Dashboard上, 這個工具就是Turbine.
Hystrix Dashboard
我們在熔斷示例項目spring-cloud-consumer-hystrix的基礎(chǔ)上更改,重新命名為:spring-cloud-consumer-hystrix-dashboard。
1、添加依賴
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency>
這三個包必須添加
2、啟動類
啟動類添加啟用Hystrix Dashboard和熔斷器
@SpringBootApplication @EnableDiscoveryClient @EnableFeignClients @EnableHystrixDashboard @EnableCircuitBreaker public class ConsumerApplication { public static void main(String[] args) { SpringApplication.run(ConsumerApplication.class, args); } }
3、測試
啟動工程后訪問 http://localhost:9001/hystrix,將會看到如下界面:
圖中會有一些提示:
Cluster via Turbine (default cluster): http://turbine-hostname:port/turbine.stream
Cluster via Turbine (custom cluster): http://turbine-hostname:port/turbine.stream?cluster=[clusterName]
Single Hystrix App: http://hystrix-app:port/hystrix.stream
大概意思就是如果查看默認集群使用第一個url,查看指定集群使用第二個url,單個應(yīng)用的監(jiān)控使用最后一個,我們暫時只演示單個應(yīng)用的所以在輸入框中輸入:
http://localhost:9001/hystrix.stream ,輸入之后點擊 monitor,進入頁面。
如果沒有請求會先顯示Loading ...
,訪問http://localhost:9001/hystrix.stream 也會不斷的顯示ping。
請求服務(wù)http://localhost:9001/hello/neo,就可以看到監(jiān)控的效果了,首先訪問http://localhost:9001/hystrix.stream,顯示如下:
ping:
data: {"type":"HystrixCommand","name":"HelloRemote#hello(String)","group":"spring-cloud-producer","currentTime":1494915453986,"isCircuitBreakerOpen":false,"errorPercentage":100,"errorCount":1,"requestCount":1,"rollingCountBadRequests":0,"rollingCountCollapsedRequests":0,"rollingCountEmit":0,"rollingCountExceptionsThrown":0,"rollingCountFailure":0,"rollingCountFallbackEmit":0,"rollingCountFallbackFailure":0,"rollingCountFallbackMissing":0,"rollingCountFallbackRejection":0,"rollingCountFallbackSuccess":1,"rollingCountResponsesFromCache":0,"rollingCountSemaphoreRejected":0,"rollingCountShortCircuited":0,"rollingCountSuccess":0,"rollingCountThreadPoolRejected":0,"rollingCountTimeout":1,"currentConcurrentExecutionCount":0,"rollingMaxConcurrentExecutionCount":0,"latencyExecute_mean":0,"latencyExecute":{"0":0,"25":0,"50":0,"75":0,"90":0,"95":0,"99":0,"99.5":0,"100":0},"latencyTotal_mean":0,"latencyTotal":{"0":0,"25":0,"50":0,"75":0,"90":0,"95":0,"99":0,"99.5":0,"100":0},"propertyValue_circuitBreakerRequestVolumeThreshold":20,"propertyValue_circuitBreakerSleepWindowInMilliseconds":5000,"propertyValue_circuitBreakerErrorThresholdPercentage":50,"propertyValue_circuitBreakerForceOpen":false,"propertyValue_circuitBreakerForceClosed":false,"propertyValue_circuitBreakerEnabled":true,"propertyValue_executionIsolationStrategy":"THREAD","propertyValue_executionIsolationThreadTimeoutInMilliseconds":1000,"propertyValue_executionTimeoutInMilliseconds":1000,"propertyValue_executionIsolationThreadInterruptOnTimeout":true,"propertyValue_executionIsolationThreadPoolKeyOverride":null,"propertyValue_executionIsolationSemaphoreMaxConcurrentRequests":10,"propertyValue_fallbackIsolationSemaphoreMaxConcurrentRequests":10,"propertyValue_metricsRollingStatisticalWindowInMilliseconds":10000,"propertyValue_requestCacheEnabled":true,"propertyValue_requestLogEnabled":true,"reportingHosts":1,"threadPool":"spring-cloud-producer"}
data: {"type":"HystrixThreadPool","name":"spring-cloud-producer","currentTime":1494915453986,"currentActiveCount":0,"currentCompletedTaskCount":1,"currentCorePoolSize":10,"currentLargestPoolSize":1,"currentMaximumPoolSize":10,"currentPoolSize":1,"currentQueueSize":0,"currentTaskCount":1,"rollingCountThreadsExecuted":0,"rollingMaxActiveThreads":0,"rollingCountCommandRejections":0,"propertyValue_queueSizeRejectionThreshold":5,"propertyValue_metricsRollingStatisticalWindowInMilliseconds":10000,"reportingHosts":1}
說明已經(jīng)返回了監(jiān)控的各項結(jié)果
到監(jiān)控頁面就會顯示如下圖:
其實就是http://localhost:9001/hystrix.stream返回結(jié)果的圖形化顯示,Hystrix Dashboard Wiki上詳細說明了圖上每個指標的含義,如下圖:
到此單個應(yīng)用的熔斷監(jiān)控已經(jīng)完成。
Turbine
在復(fù)雜的分布式系統(tǒng)中,相同服務(wù)的節(jié)點經(jīng)常需要部署上百甚至上千個,很多時候,運維人員希望能夠把相同服務(wù)的節(jié)點狀態(tài)以一個整體集群的形式展現(xiàn)出來,這樣可以更好的把握整個系統(tǒng)的狀態(tài)。 為此,Netflix提供了一個開源項目(Turbine)來提供把多個hystrix.stream的內(nèi)容聚合為一個數(shù)據(jù)源供Dashboard展示。
1、添加依賴
<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.cloud</groupId> <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId> </dependency> </dependencies>
2、配置文件
spring.application.name=hystrix-dashboard-turbine server.port=8001 turbine.appConfig=node01,node02 turbine.aggregator.clusterConfig= default turbine.clusterNameExpression= new String("default") eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/
turbine.appConfig
:配置Eureka中的serviceId列表,表明監(jiān)控哪些服務(wù)turbine.aggregator.clusterConfig
:指定聚合哪些集群,多個使用”,”分割,默認為default。可使用http://.../turbine.stream?cluster={clusterConfig之一}
訪問turbine.clusterNameExpression
: 1. clusterNameExpression指定集群名稱,默認表達式appName;此時:turbine.aggregator.clusterConfig
需要配置想要監(jiān)控的應(yīng)用名稱;2. 當(dāng)clusterNameExpression: default時,turbine.aggregator.clusterConfig
可以不寫,因為默認就是default;3. 當(dāng)clusterNameExpression: metadata[‘cluster']時,假設(shè)想要監(jiān)控的應(yīng)用配置了eureka.instance.metadata-map.cluster: ABC
,則需要配置,同時turbine.aggregator.clusterConfig: ABC
3、啟動類
啟動類添加@EnableTurbine
,激活對Turbine的支持
@SpringBootApplication @EnableHystrixDashboard @EnableTurbine public class DashboardApplication { public static void main(String[] args) { SpringApplication.run(DashboardApplication.class, args); } }
到此Turbine(hystrix-dashboard-turbine)配置完成
4、測試
在示例項目spring-cloud-consumer-hystrix基礎(chǔ)上修改為兩個服務(wù)的調(diào)用者spring-cloud-consumer-node1和spring-cloud-consumer-node2
spring-cloud-consumer-node1項目改動如下:
application.properties文件內(nèi)容
spring.application.name=node01 server.port=9001 feign.hystrix.enabled=true eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/
spring-cloud-consumer-node2項目改動如下:
application.properties文件內(nèi)容
spring.application.name=node02 server.port=9002 feign.hystrix.enabled=true eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/
HelloRemote類修改:
@FeignClient(name= "spring-cloud-producer2", fallback = HelloRemoteHystrix.class) public interface HelloRemote { @RequestMapping(value = "/hello") public String hello2(@RequestParam(value = "name") String name); }
對應(yīng)的HelloRemoteHystrix
和ConsumerController
類跟隨修改,具體查看代碼
修改完畢后,依次啟動spring-cloud-eureka、spring-cloud-consumer-node1、spring-cloud-consumer-node1、hystrix-dashboard-turbine(Turbine)
打開eureka后臺可以看到注冊了三個服務(wù):
訪問 http://localhost:8001/turbine.stream
返回:
: ping data: {"reportingHostsLast10Seconds":1,"name":"meta","type":"meta","timestamp":1494921985839}
并且會不斷刷新以獲取實時的監(jiān)控數(shù)據(jù),說明和單個的監(jiān)控類似,返回監(jiān)控項目的信息。進行圖形化監(jiān)控查看,輸入:http://localhost:8001/hystrix,返回酷酷的小熊界面,輸入: http://localhost:8001/turbine.stream,然后點擊 Monitor Stream ,可以看到出現(xiàn)了倆個監(jiān)控列表
參考:
使用Spring Cloud與Docker實戰(zhàn)微服務(wù)
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
java實現(xiàn)響應(yīng)重定向發(fā)送post請求操作示例
這篇文章主要介紹了java實現(xiàn)響應(yīng)重定向發(fā)送post請求操作,結(jié)合實例形式分析了java請求響應(yīng)、重定向及數(shù)據(jù)處理相關(guān)操作技巧,需要的朋友可以參考下2020-04-04Spring2.5.6開發(fā)環(huán)境搭建圖文教程
這篇文章主要為大家詳細介紹了Spring2.5.6開發(fā)環(huán)境搭建圖文教程,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-05-05Spring Boot 2.5.0 重新設(shè)計的spring.sql.init 配置有啥用
前幾天Spring Boot 2.5.0發(fā)布了,其中提到了關(guān)于Datasource初始化機制的調(diào)整,有讀者私信想了解這方面做了什么調(diào)整。那么今天就要詳細說說這個重新設(shè)計的配置內(nèi)容,并結(jié)合實際情況說說我的理解和實踐建議2021-05-05Mybatis plus 配置多數(shù)據(jù)源的實現(xiàn)示例
這篇文章主要介紹了Mybatis plus 配置多數(shù)據(jù)源的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08詳解SpringBoot修改啟動端口server.port的四種方式
這篇文章主要介紹了詳解SpringBoot修改啟動端口server.port的四種方式,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07設(shè)計模式在Spring框架中的應(yīng)用匯總
這篇文章主要介紹了設(shè)計模式在Spring框架中的應(yīng)用匯總,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-11-11java?數(shù)組實現(xiàn)學(xué)生成績統(tǒng)計教程
這篇文章主要介紹了java?數(shù)組實現(xiàn)學(xué)生成績統(tǒng)計教程,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-12-12