springcloud(五)：熔斷監控Hystrix Dashboard和Turbine

Hystrix-dashboard是一款針對Hystrix進行實時監控的工具，經過Hystrix Dashboard咱們能夠在直觀地看到各Hystrix Command的請求響應時間, 請求成功率等數據。可是隻使用Hystrix Dashboard的話, 你只能看到單個應用內的服務信息, 這明顯不夠. 咱們須要一個工具能讓咱們彙總系統內多個服務的數據並顯示到Hystrix Dashboard上, 這個工具就是Turbine.node

Hystrix Dashboard

咱們在熔斷示例項目spring-cloud-consumer-hystrix的基礎上更改，從新命名爲：spring-cloud-consumer-hystrix-dashboard。spring

一、添加依賴

<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>

這三個包必須添加app

二、啓動類

啓動類添加啓用Hystrix Dashboard和熔斷器運維

@SpringBootApplication @EnableDiscoveryClient @EnableFeignClients @EnableHystrixDashboard @EnableCircuitBreaker public class ConsumerApplication { public static void main(String[] args) { SpringApplication.run(ConsumerApplication.class, args); } }

三、測試

啓動工程後訪問 http://localhost:9001/hystrix，將會看到以下界面：分佈式

圖中會有一些提示：spring-boot

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,單個應用的監控使用最後一個，咱們暫時只演示單個應用的因此在輸入框中輸入： http://localhost:9001/hystrix.stream ，輸入以後點擊 monitor，進入頁面。工具

若是沒有請求會先顯示Loading ...，訪問http://localhost:9001/hystrix.stream 也會不斷的顯示ping。測試

請求服務http://localhost:9001/hello/neo，就能夠看到監控的效果了，首先訪問http://localhost:9001/hystrix.stream，顯示以下：ui

ping: data: {"type":...} data: {"type":...}

說明已經返回了監控的各項結果url

到監控頁面就會顯示以下圖：

其實就是http://localhost:9001/hystrix.stream返回結果的圖形化顯示，Hystrix Dashboard Wiki上詳細說明了圖上每一個指標的含義，以下圖：

到此單個應用的熔斷監控已經完成。

Turbine

在複雜的分佈式系統中，相同服務的節點常常須要部署上百甚至上千個，不少時候，運維人員但願可以把相同服務的節點狀態以一個總體集羣的形式展示出來，這樣能夠更好的把握整個系統的狀態。爲此，Netflix提供了一個開源項目（Turbine）來提供把多個hystrix.stream的內容聚合爲一個數據源供Dashboard展現。

一、添加依賴

<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>

二、配置文件

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列表，代表監控哪些服務
turbine.aggregator.clusterConfig ：指定聚合哪些集羣，多個使用」,」分割，默認爲default。可以使用http://.../turbine.stream?cluster={clusterConfig之一}訪問
turbine.clusterNameExpression ： 1. clusterNameExpression指定集羣名稱，默認表達式appName；此時：turbine.aggregator.clusterConfig須要配置想要監控的應用名稱；2. 當clusterNameExpression: default時，turbine.aggregator.clusterConfig能夠不寫，由於默認就是default；3. 當clusterNameExpression: metadata[‘cluster’]時，假設想要監控的應用配置了eureka.instance.metadata-map.cluster: ABC，則須要配置，同時turbine.aggregator.clusterConfig: ABC

三、啓動類

啓動類添加@EnableTurbine，激活對Turbine的支持

@SpringBootApplication @EnableHystrixDashboard @EnableTurbine public class DashboardApplication { public static void main(String[] args) { SpringApplication.run(DashboardApplication.class, args); } }

到此Turbine（hystrix-dashboard-turbine）配置完成

四、測試

在示例項目spring-cloud-consumer-hystrix基礎上修改成兩個服務的調用者spring-cloud-consumer-node1和spring-cloud-consumer-node2

spring-cloud-consumer-node1項目改動以下： application.properties文件內容

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文件內容

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); }

對應的HelloRemoteHystrix和ConsumerController類跟隨修改，具體查看代碼

修改完畢後，依次啓動spring-cloud-eureka、spring-cloud-consumer-node一、spring-cloud-consumer-node一、hystrix-dashboard-turbine（Turbine）

打開eureka後臺能夠看到註冊了三個服務：

訪問 http://localhost:8001/turbine.stream

: ping data: {"reportingHostsLast10Seconds":1,"name":"meta","type":"meta","timestamp":1494921985839}

而且會不斷刷新以獲取實時的監控數據，說明和單個的監控相似，返回監控項目的信息。進行圖形化監控查看，輸入：http://localhost:8001/hystrix，返回酷酷的小熊界面，輸入： http://localhost:8001/turbine.stream，而後點擊 Monitor Stream ,能夠看到出現了倆個監控列表