Spring Cloud快速开发入门第八篇---Hystrix集群监控Turbine

た入场券 2021-11-04 17:16 306阅读 0赞

本文是Spring Cloud专栏的第八篇文章，了解前七篇文章内容有助于更好的理解本文：

1.  [Spring Cloud快速开发入门第一篇---SpringCloud前言及其常用组件介绍概览][Spring Cloud_---SpringCloud]
2.  [Spring Cloud快速开发入门第二篇---使用并认识Eureka注册中心][Spring Cloud_---_Eureka]
3.  [Spring Cloud快速开发入门第三篇---搭建高可用Eureka注册中心][Spring Cloud_---_Eureka 1]
4.  [Spring Cloud快速开发入门第四篇---客户端负载均衡Ribbon][Spring Cloud_---_Ribbon]
5.  [Spring Cloud快速开发入门第五篇---服务熔断Hystrix][Spring Cloud_---_Hystrix]
6.  [Spring Cloud快速开发入门第六篇---Hystrix仪表盘监控Hystrix Dashboard][Spring Cloud_---Hystrix_Hystrix Dashboard]
7.  [Spring Cloud快速开发入门第七篇---声明式服务调用Feign][Spring Cloud_---_Feign]

![20190814093913323.gif][]

# 一、前言 #

[Spring Cloud快速开发入门第六篇---Hystrix仪表盘监控Hystrix Dashboard][Spring Cloud_---Hystrix_Hystrix Dashboard]一文我们看了一个监控单体应用的例子，在实际应用中，我们要监控的应用往往是一个集群，这个时候我们就得采取Turbine集群监控了。Turbine有一个重要的功能就是汇聚监控信息，并将汇聚到的监控信息提供给Hystrix Dashboard来集中展示和监控。那我们就来看看Turbine集群监控如何使用。

Turbine所处的作用如图：

![aHR0cHM6Ly9zczEuYmRzdGF0aWMuY29tLzcwY0Z1WFNoX1ExWW54R2twb1dLMUhGNmhoeS9pdC91PTg5MzkyMTg4LDQ3MjI2Mzk0MSZmbT0xNSZncD0wLmpwZw][]

# 二、Turbine的应用 #

1-1、创键turbine模块（springcloud-hystrix-turbine）

1-2、添加依赖

<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-turbine</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    		</dependency>

1-3、在启动类上添加注解

@EnableDiscoveryClient //和该注解@EnableEurekaClient功能一样 //开启eureka客户端功能
    @EnableTurbine //开启turibine相关支持

1-4、修改application.yml

server:
      port: 2002
    spring:
      application:
        name: springcloud-hystrix-turbine
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8700/eureka
        #客户端每隔30秒从Eureka服务上更新一次服务信息
        registry-fetch-interval-seconds: 30
        #需要将我的服务注册到eureka上
        register-with-eureka: true
        #需要检索服务
        fetch-registry: true
    
      #心跳检测检测与续约时间
      instance:
        #告诉服务端，如果我10s之内没有给你发心跳，就代表我故障了，将我剔除掉，默认90s
        #Eureka服务端在收到最后一次心跳之后等待的时间上限，单位为秒，超过则剔除（客户端告诉服务端按照此规则等待自己）
        lease-expiration-duration-in-seconds: 10
        #每隔2s向服务端发送一次心跳，证明自已依然活着，默认30s
        #Eureka客户端向服务端发送心跳的时间间隔，单位为秒（客户端告诉服务端自己会按照该规则）
        lease-renewal-interval-in-seconds: 2
        # 启用ip配置 这样在注册中心列表中看见的是以ip+端口呈现的
        prefer-ip-address: true
        # 实例名称  最后呈现地址：ip:2002
        instance-id: ${spring.cloud.client.ip-address}:${server.port}
    
    turbine:
    # true 同一主机上的服务通过host和port的组合来进行区分，默认为true
    # false 时 在本机才是时 监控中host集群数会为1了 因为本地host是一样的
      combine-host-port: true
      #turbine.app-config: 配置Euraka中的serviceId列表，表明监控哪些服务
      app-config: springcloud-service-consumer
      #turbine.cluster-name-expression参数指定了集群名称为default,
      #当服务的数量非常多的时候,可以启动多个Turbine服务来构建不同的聚合集群,
      #而该参数可以用来区分这些不同的聚合集群,同时该参数值可以在 Hystrix仪表盘中用来定位
      #不同的聚合集群,只需在 Hystrix Stream的URL中通过 cluster参数来指定;
      cluster-name-expression: new String('default')

turbine.cluster-name-expression参数指定了集群名称为default,当服务数量非常多的时候,可以启动多个Turbine服务来构建不同的聚合集群,而该参数可以用来区分这些不同的聚合集群,同时该参数值可以在 Hystrix仪表盘中用来定位不同的聚合集群,只需在 Hystrix Stream的URL中通过 cluster参数来指定; turbine.combine-host-port参数设置为true,可以让同一主机上的服务通过主机名与端口号的组合来进行区分,默认情况下会以host来区分不同的服务,这 会使得在本地调试的时候,本机上的不同服务聚合成一个服务来统计。

1-5、在完成上面的构建之后，我们体验下Turbine对集群的监控能力。分别启动注册中心（springcloud-eureka-server），消费者启动两个（springcloud-service-consumer/9090，springcloud-service-consumer/9091），服务提供者（springcloud-service-provider），Hystrix Dashboard（springcloud-hystrix-dashboard），Turbine模块（springcloud-hystrix-turbine）

查看注册中心上注册的服务为：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70][]

在 Hystrix仪表盘上输入turbine的/turbine.stream端点  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 1][]

如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 2][]

从图中可以看到,虽然我们如之前的架构那样启动了两个 springcloud-service-consumer,但是 在监控页面中依然只是展示了一个监控图。不过仔细的话可能已经发现,图中集群报告区域中的 Hosts属性与之前尝试单机监控时已经有所不同。由此我们可以知道 springcloud-service-consumer启动了两个实例,这里只展现了一个监控图,是由于这两个实例是同 一个服务,而对于集群来说我们关注的是服务集群的高可用性,所以 Turbine会将相同服务作为整体来看待,并汇总成一个监控图。

我们不区分集群的话，我们启动很多服务都是在这个界面上看到的，都聚合到一起了，如果我们集群很多，想要分集群查看，如下步骤。

# 三、Turbine自定义集群监控 #

如果微服务数量特别多，我们想要监控某个服务集群的状况可以配置如下：

这次启动消费者模块（springcloud-service-consumer，springcloud-service-feign）

2-1、我们需要修改消费者模块（springcloud-service-consumer，springcloud-service-feign）的application.yml

springcloud-service-consumer添加配置为：

eureka.instance.metadata-map.cluster:consumer

springcloud-service-feign添加配置为：

eureka.instance.metadata-map.cluster: feign

2-2、修改Turbine模块的application.yml配置如下，只列出turbine相关配置其他配置看源码案例

turbine:
      # true 同一主机上的服务通过host和port的组合来进行区分，默认为true
      # false 时 在本机才是时监控中host集群数会为1了因为本地host是一样的
      combine-host-port: true
      aggregator:
       #指定聚合哪些集群, 多个使用","分割, 默认为default
       #可使用http://.../turbine.stream?cluster={clusterConfig之一}访问
        cluster-config: consumer,feign
    
      #turbine.app-config: 配置Euraka中的serviceId列表，表明监控哪些服务
      app-config: springcloud-service-consumer,springcloud-service-feign
      #指定集群名称，默认表达式appName
      #turbine.cluster-name-expression参数指定了集群名称为default,
      #当服务的数量非常多的时候,可以启动多个Turbine服务来构建不同的聚合集群,
      #而该参数可以用来区分这些不同的聚合集群,同时该参数值可以在 Hystrix仪表盘中用来定位
      #不同的聚合集群,只需在 Hystrix Stream的URL中通过 cluster参数来指定
      # 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
      #cluster-name-expression: "'default'"
      cluster-name-expression: metadata['cluster']

2-3、在主类上必须添加@EnableCircuitBreaker该注解，不然端点/actuator/hystrix.stream不会暴露出来

2-4、访问turbine的clusters端口[http://localhost:2002/clusters][http_localhost_2002_clusters]，查看如图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 3][]

2-5、在hystrix Dashboard输入turbine的地址，指定集群，例如如图：

consumer集群：[http://localhost:2002/turbine.stream?cluster=consumer][http_localhost_2002_turbine.stream_cluster_consumer]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 4][]

feign集群：[http://localhost:2002/turbine.stream?cluster=feign][http_localhost_2002_turbine.stream_cluster_feign]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 5][]

2-5、我们可以看到我们指定的集群状况信息

consumer集群状况信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 6][]

feign集群状况信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 7][]

这样区分的作用是，如果工地有很多的服务，可以通过区分集群来分别查看

详细参考案例源码。

[Spring Cloud_---SpringCloud]: https://blog.csdn.net/qq_39669058/article/details/97896801
[Spring Cloud_---_Eureka]: https://blog.csdn.net/qq_39669058/article/details/98061066
[Spring Cloud_---_Eureka 1]: https://blog.csdn.net/qq_39669058/article/details/98083411
[Spring Cloud_---_Ribbon]: https://blog.csdn.net/qq_39669058/article/details/98232020
[Spring Cloud_---_Hystrix]: https://blog.csdn.net/qq_39669058/article/details/98232459
[Spring Cloud_---Hystrix_Hystrix Dashboard]: https://blog.csdn.net/qq_39669058/article/details/98234342
[Spring Cloud_---_Feign]: https://blog.csdn.net/qq_39669058/article/details/98234513
[20190814093913323.gif]: /images/20211104/6e27f5ab68184ecca34baf792d5d5518.png
[aHR0cHM6Ly9zczEuYmRzdGF0aWMuY29tLzcwY0Z1WFNoX1ExWW54R2twb1dLMUhGNmhoeS9pdC91PTg5MzkyMTg4LDQ3MjI2Mzk0MSZmbT0xNSZncD0wLmpwZw]: /images/20211104/b69cd0ecc0404251b47633fa674c7cd3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70]: /images/20211104/4a9a9ef8b6404db68a10a42a3ebf201b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 1]: /images/20211104/bae5d976b4604aabb6fb0940b52a6c57.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 2]: /images/20211104/cd6d6ab414da495fb432ae7145732cd3.png
[http_localhost_2002_clusters]: http://localhost:2002/clusters
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 3]: /images/20211104/9cc29fc5d3984c7cba7e4e38d7059310.png
[http_localhost_2002_turbine.stream_cluster_consumer]: http://localhost:2002/turbine.stream?cluster=consumer
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 4]: /images/20211104/ccc65be943514a4884b404d6aa9430a5.png
[http_localhost_2002_turbine.stream_cluster_feign]: http://localhost:2002/turbine.stream?cluster=feign
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 5]: /images/20211104/c3cf63aa51b74498aa271b8af173e0ab.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 6]: /images/20211104/3945c178a1584175af237472b66c5394.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5NjY5MDU4_size_16_color_FFFFFF_t_70 7]: /images/20211104/f598ee7190f440d5a94bc20f74ec5e48.png