springCloud - 第13篇 - 服务监控集群模式 Hystrix-turbine

逃离我推掉我的手 2021-10-13 01:19 374阅读 0赞

[前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到教程。][Link 1]

1. 在springcloud 体系中，可以用 hystrix-dashboard  实时监控服务的运行状态。上一文记录了单实例的监控，现在实现集群监控。

2. 新建工程 hystrix-turbine 作为集群监控的实现服务。

2.1 file - new - module

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70][]

2.2  spring Initializr - module SDK 选择自己的 JDK ，其余的可以不用填写，next。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 1][]

2.3 填写工程相关信息：包名、工程名等，next。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 2][]

2.4 此步只是帮助自动生成依赖，可不选，直接 next。

2.5 工程名，代码存放位置等，finish 。

![20190820114720711.png][]

2.6 生成工程的结构如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 3][]

2.7 pom.xml 重用 hystrix-dashboard 的依赖，另新增少量依赖：

2.8 启动类：

package com.hystrixturbine;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.turbine.EnableTurbine;
    
    
    //监控面板-集群
    @EnableTurbine
    
    @SpringBootApplication
    public class HystrixTurbineApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(HystrixTurbineApplication.class, args);
    	}
    
    }

2.9 配置文件 application.properties：

# 注册中心 - 端口： 1234、工程名： eureka （见 eureka 工程中配置）。
    eureka.client.serviceUrl.defaultZone= http://localhost:1234/eureka/
    
    # 端口
    server.port= 8889
    
    # 工程名
    spring.application.name= hystrix-turbine
    
    # 被监控服务名称
    turbine.app-config= ribbon,feign
    
    # 集群名称为“default”。
    # 应用服务很多时，可用多个 hystrix-turbine 来监控不同的聚合集群，集群名可区分这些不同的聚合集群，
    # 此集群名亦可在 hystrix-dashboard 中用来定位不同的聚合集群：
    # 即：“http://turbine-hostname:port/turbine.stream?cluster=[clusterName]” 中对应 “clusterName”便可。
    turbine.cluster-name-expression= "default"
    
    # 同一主机上的服务通过主机名与端口号的组合来进行区分，默认以 host 区分服务，
    # 这样，本地调试时，本机上的不同服务则会聚合成一个服务来统计。
    turbine.combine-host-port= true

3. 类同已有的 ribbon 工程，调整已有工程 feign 工程。

3.1 增加依赖 spring-cloud-starter-netflix-hystrix，此时 feign工程完整 pom 为：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.feign</groupId>
        <artifactId>service-feign</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
        <name>service-feign</name>
        <description>服务消费 feign 方式</description>
    
        <parent>
            <groupId>com.base</groupId>
            <artifactId>base-config</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
    
        <dependencies>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
        </dependencies>
    
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/milestone</url>
                <snapshots>
                    <enabled>false</enabled>
                </snapshots>
            </repository>
        </repositories>
    
    </project>

3.2 配置文件中加上 hystrix 相关配置，完整配置为：

# 注册中心 - 端口： 1234、工程名： eureka （见 eureka 工程中配置）。
    eureka.client.serviceUrl.defaultZone= http://localhost:1234/eureka/
    
    # 端口
    server.port= 8702
    
    # 工程名
    spring.application.name= feign
    
    # 开启断熔器： （ Feign 自带断路器，但默认为不开启： false）
    feign.hystrix.enabled=true
    
    # 也可配置为'*' ，纳入 hystrix 服务监控
    management.endpoints.web.exposure.include= hystrix.stream

3.3  启动类确认注解 ：@EnableHystrix，同时加上 hystrixMetricsStreamServlet 方法，完整启动类为：

package com.feign.servicefeign;
    
    import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.web.servlet.ServletRegistrationBean;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.cloud.netflix.hystrix.EnableHystrix;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    import org.springframework.context.annotation.Bean;
    
    @SpringBootApplication
    
    /**
     * 基于接口的注解，可插拔，可使用 Feign注解 和 JAX-RS注解
     * Feign 默认集成 Ribbon，并和 Eureka 结合，默认实现负载均衡。
     */
    @EnableFeignClients
    
    // 标明自已为服务
    @EnableEurekaClient
    
    // 开启断路器： Hystrix
    @EnableHystrix
    public class ServiceFeignApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(ServiceFeignApplication.class, args);
    	}
    
        @Bean
        public ServletRegistrationBean hystrixMetricsStreamServlet() {
            ServletRegistrationBean registration = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
            registration.addUrlMappings("/hystrix.stream");
            return registration;
        }
    }

4. 依次启动工程： 注册中心 eureka ( 端口 1234 ) 、 服务应用 ribbon  ( 端口 8701 ) 、服务应用 feign ( 端口 8702)、

监控集群服务 hystrix-turbine ( 端口 8889)、监控仪表盘hystrix-dashboard  ( 端口 8888) 。

其中，服务应用 ribbon、feign 都调用第三方服务应用：seeParam  ( 端口 8801) 。

4.1 seeParam 工程未启动，由于有熔断机制，访问 feign 工程效果为：

![20190820134136891.png][]

4.2 同样，seeParam 工程未启动，由于有熔断机制，访问 ribbon 工程效果为：

![20190820134220861.png][]

4.3 访问 [http://localhost:8888/hystrix.stream][http_localhost_8888_hystrix.stream] ，可看到和单实例监控界面入口一样的面板界面。

此时，在 hystrix-dashboard 中使用集群监控的 URL 查看监控信息，在页面第一个输入框中输入 hystrix-turbine 工程的访问路径：[http://localhost:8889/turbine.stream][http_localhost_8889_turbine.stream]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 4][]

4.4  进入实时监控显示页面可看到 ，刚才已经多次刷新过请求的 feign、ribbon 工程的运行状况统计信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 5][]

红色 100% 表示 请求 seeParam 工程失败。球体为红色也表明服务健康状态为最差。

4.5 启动  seeParam 工程后，请求其接口：

![20190820135217779.png][]

再多次刷新 feign、ribbon 的请求后，分别请求到了 seeParam 的接口：

![20190820135433893.png][]

![2019082013550011.png][]

此时，再查看 hysteix-dashboard 中的服务统计信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 6][]

失败请求率为 0.0%，球体也变为绿色，表示服务运行正常。

至此，服务监控的集群模式也实现了。

\-------------------------------------------------------------

下一篇：springCloud - 第14篇 -

源码见：

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-feign][https_gitee.com_FJ_WoMenDeShiJie_springcloud-feign]

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-ribbon][https_gitee.com_FJ_WoMenDeShiJie_springcloud-ribbon]

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-seeParam][https_gitee.com_FJ_WoMenDeShiJie_springcloud-seeParam]

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-hystrix-turbine][https_gitee.com_FJ_WoMenDeShiJie_springcloud-hystrix-turbine]

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-hystrix-dashboard][https_gitee.com_FJ_WoMenDeShiJie_springcloud-hystrix-dashboard]

\-------------------------------------------------------------

PS：这个系列不定时更新，只是个人的学习分享，

内容全程参考书目：

《Spring Cloud 与 Docker 微服务架构空实战 》、

《Spring Cloud 微服务实战》及此书作者博客：http://blog.didispace.com/spring-cloud-learning/

《深入理解 Spring Cloud 与微服务构建》及此书作者博客：https://blog.csdn.net/forezp/article/details/70148833

\----------------------------------------------------------------

[Link 1]: https://www.captainai.net/jiangyu1013/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70]: /images/20211013/9d2aaa5665bb4c3381d026cf86bbe422.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 1]: /images/20211013/3da9f755efda4a978843b0f33a8def1d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 2]: /images/20211013/8419d963f01047888b6786818ba86172.png
[20190820114720711.png]: /images/20211013/121f6c7e56314b7dbd3642bacbb2a05f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 3]: /images/20211013/7669ba9a0157419aa8ac8bf8f16edfe1.png
[20190820134136891.png]: /images/20211013/6515e684e915404080ac954b1c62a4e6.png
[20190820134220861.png]: /images/20211013/e1856ffb76b54f46a866a6f784034122.png
[http_localhost_8888_hystrix.stream]: http://localhost:8888/hystrix.stream
[http_localhost_8889_turbine.stream]: http://localhost:8889/turbine.stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 4]: /images/20211013/06fc3703d63841bebe86d557aac2d6b2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 5]: /images/20211013/9afd32a96fdf4cef9888de11ce3f8060.png
[20190820135217779.png]: /images/20211013/fb1ba74cd7784ac4ac9e2e5e21747c69.png
[20190820135433893.png]: /images/20211013/ddb9f73d64574f268784e0fcef2ef949.png
[2019082013550011.png]: /images/20211013/a7dcba5557374da6b8a00490918a1adb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 6]: /images/20211013/465a840215ab478088573bd52f47eae5.png
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-feign]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-feign
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-ribbon]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-ribbon
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-seeParam]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-seeParam
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-hystrix-turbine]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-hystrix-turbine
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-hystrix-dashboard]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-hystrix-dashboard