Turbine聚合服务 + Hystrix-Dashboard集成大盘监控

我会带着你远行 2023-01-01 05:50 101阅读 0赞

#### Turbine聚合服务 ####

Turbine的聚合比较简单，只需要添加注解和填好配置文件即可

*  pom文件

<dependencies>
        <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.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-turbine</artifactId>
        </dependency>
    </dependencies>

*  启动类application

@EnableDiscoveryClient
    @EnableHystrix
    @EnableCircuitBreaker
    @EnableTurbine
    @EnableAutoConfiguration
    public class TurbineApplication { 
    
        public static void main(String[] args) throws NoSuchMethodException { 
            new SpringApplicationBuilder(TurbineApplication.class)
                    .web(WebApplicationType.SERVLET)
                    .run(args);
    
        }
    }

*  配置文件

eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:20000/eureka/
    management:
      port: 52001
    server:
      port: 52000
    spring:
      application:
        name: hystrix-turbine
    turbine:
      aggregator:
        clusterConfig: default
      app-config: hystrix-consumer  # 指定了所需要监控的服务名
      cluster-name-expression: '"default"'  # 在实际使用中，我们应该使用多个Turbine监控多台机器，然后再做聚合，在这里作为演示，配置default即可
      combine-host-port: true # 将端口和hostname作为区分不同服务的条件（默认只使用Host）
      instanceUrlSuffix:
        default: actuator/hystrix.stream

我们要在准备开启监控的`hystrix-consumer`服务中，开启actuator

management:
      endpoint:
        health:
          show-details: always
      endpoints:
        web:
          exposure:
            include: '*'
      security:
        enabled: false

我们依此启动Eureka -> Feign -> Hystrix -> Turbine  
我们尝试调用`localhost:52000/turbine.stream`，能看到已经可以获取`hystrix-consumer`暴露出来的统计信息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70]

#### Hystrix-Dashboard集成大盘监控 ####

*  pom文件

<dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
        </dependency>
    
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
    
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
    </dependencies>

*  启动类application

@EnableHystrixDashboard
    @SpringCloudApplication
    public class HystrixDashboardApplication { 
    
        public static void main(String[] args) { 
            new SpringApplicationBuilder(HystrixDashboardApplication.class)
                    .web(WebApplicationType.SERVLET)
                    .run(args);
    
        }
    }

*  配置文件

server:
      port: 53000
    spring:
      application:
        name: hystrix-dashboard

我们依此启动Eureka -> Feign -> Hystrix -> Turbine -> Dashboard  
访问`localhost:53000/hystrix`，可以看到如下页面：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 1]  
前文提到我们有两个监控路径：

*  Hystrix监控路径: http://localhost:50000/actuator/hystrix.stream
 *  Turbine监控路径: http://localhost:52000/turbine.stream

前者为Hystrix的监控信息，后者为Turbine聚合后的信息，在这里我们填入`http://localhost:52000/turbine.stream`， 可以看到以下页面：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 2]

我们调用[《Hystrix使用多级降级》][Hystrix]中的`localhost:50000/fallback`接口，可以看到已经出现了监控的数据

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70]: /images/20221120/1b499d42fd4745ab853c62e1e3b0c052.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 1]: /images/20221120/741055c339824ec49186181c4b54eb31.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 2]: /images/20221120/25cf282fc65a4f2aa260317d455df7cd.png
[Hystrix]: https://jiandansuifeng.blog.csdn.net/article/details/112015519
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x0MzI2MDMwNDM0_size_16_color_FFFFFF_t_70 3]: /images/20221120/01864b27cf654f52a57093ff87be6837.png