小編給大家分享一下Spring Cloud斷路器集群監(jiān)控的示例分析，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

專注于為中小企業(yè)提供網(wǎng)站設(shè)計(jì)、成都網(wǎng)站設(shè)計(jì)服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)雨城免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了1000多家企業(yè)的穩(wěn)健成長(zhǎng)，幫助中小企業(yè)通過網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

一. 簡(jiǎn)介

在實(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)入必要的依賴：

 
 
  4.0.0 
 
  com.dan 
  service-turbine 
  0.0.1-SNAPSHOT 
  jar 
 
  service-turbine 
  Demo project for Spring Boot 
 
   
    org.springframework.boot 
    spring-boot-starter-parent 
    1.5.9.RELEASE 
      
   
 
   
    UTF-8 
    UTF-8 
    1.8 
    Edgware.SR1 
   
 
   
  
 org.springframework.cloud 
 spring-cloud-starter-turbine 
  
  
 org.springframework.cloud 
 spring-cloud-netflix-turbine 
  
  
 org.springframework.boot 
 spring-boot-starter-actuator 
  
 
  
 org.springframework.boot 
 spring-boot-starter-test 
 test 
  
  
 
   
     
       
        org.springframework.cloud 
        spring-cloud-dependencies 
        ${spring-cloud.version} 
        pom 
        import 
       
     
   
 
   
     
       
        org.springframework.boot 
        spring-boot-maven-plugin 
       
     
   

在工程啟動(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ù)再?gòu)南⒋碇挟惒将@取這些監(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。

 
 
  4.0.0 
 
  com.dan 
  service-turbine-amqp 
  0.0.1-SNAPSHOT 
  jar 
 
  service-turbine-amqp 
  Demo project for Spring Boot 
 
   
    org.springframework.boot 
    spring-boot-starter-parent 
    1.5.9.RELEASE 
      
   
 
   
    UTF-8 
    UTF-8 
    1.8 
    Edgware.SR1 
   
 
   
     
      org.springframework.cloud 
      spring-cloud-starter-turbine-amqp 
     
 
           org.springframework.boot 
      spring-boot-starter-actuator 
      test 
     
   
 
   
     
       
        org.springframework.cloud 
        spring-cloud-dependencies 
        ${spring-cloud.version} 
        pom 
        import 
       
     
   
 
   
     
       
        org.springframework.boot 
        spring-boot-maven-plugin 
       
     
   

在主類中使用@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的依賴，具體如下：

 
  org.springframework.cloud 
  spring-cloud-netflix-hystrix-amqp 

完成上面的配置后，同樣啟動(dòng)所有需要的工程，同樣訪問http://localhost:8765/hystrix，輸入監(jiān)控流http://localhost:8766/turbine.stream，我們可以看到跟之前同樣的結(jié)果，只是這里的監(jiān)控信息收集是通過消息代理異步實(shí)現(xiàn)的。

以上是“Spring Cloud斷路器集群監(jiān)控的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

網(wǎng)站標(biāo)題：SpringCloud斷路器集群監(jiān)控的示例分析-創(chuàng)新互聯(lián)
分享網(wǎng)址：http://weahome.cn/article/dipdjg.html