• Hystrix Turbine聚合监控


            之前,我们针对的是一个微服务实例的Hystrix数据查询分析,在微服务架构下,一个微服务的实例往往是多个(集群化)。

      比如自动投递微服务

    • 实例1(hystrix) ip1:port1/actuator/hystrix.stream
    • 实例2(hystrix) ip2:port2/actuator/hystrix.stream
    • 实例3(hystrix) ip3:port3/actuator/hystrix.stream

    按照已有的方法,我们就可以结合dashboard仪表盘每次输入一个监控数据流url,进去查看

    手工操作能否被自动功能替代?Hystrix Turbine聚合(聚合各个实例上的hystrix监控数据)监控

    Turbine(涡轮)

            思考:微服务架构下,一个微服务往往部署多个实例,如果每次只能查看单个实例的监控,就需要经常切换很不方便,在这样的场景下,我们可以使用 HystrixTurbine 进行聚合监控,它可以把相关微服务的监控数据聚合在一起,便于查看。

    Turbine服务搭建 

    (1)新建项目lagou-cloud-hystrix-turbine-9001,引入依赖坐标

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5. <parent>
    6. <artifactId>lagou-parentartifactId>
    7. <groupId>com.lagougroupId>
    8. <version>1.0-SNAPSHOTversion>
    9. parent>
    10. <modelVersion>4.0.0modelVersion>
    11. <artifactId>lagou-cloud-hystrix-turbine-9001artifactId>
    12. <dependencies>
    13. <dependency>
    14. <groupId>org.springframework.cloudgroupId>
    15. <artifactId>spring-cloud-starter-netflix-turbineartifactId>
    16. dependency>
    17. <dependency>
    18. <groupId>org.springframework.cloudgroupId>
    19. <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
    20. dependency>
    21. dependencies>
    22. <properties>
    23. <maven.compiler.source>11maven.compiler.source>
    24. <maven.compiler.target>11maven.compiler.target>
    25. properties>
    26. project>

    2)将需要进行Hystrix监控的多个微服务配置起来,在工程application.yml中开启Turbine及进行相关配置

    1. server:
    2. port: 9001
    3. Spring:
    4. application:
    5. name: lagou-cloud-hystrix-turbine
    6. eureka:
    7. client:
    8. serviceUrl: # eureka server的路径
    9. defaultZone: http://LagouCloudEurekaServerB:8762/eureka,http://LagouCloudEurekaServerA:8761/eureka #把 eureka 集群中的所有 url 都填写了进来,也可以只写⼀台,因为各个 eureka server 可以同步注册表
    10. instance:
    11. #使⽤ip注册,否则会使⽤主机名注册了(此处考虑到对⽼版本的兼容,新版本经过实验都是ip)
    12. prefer-ip-address: true
    13. #⾃定义实例显示格式,加上版本号,便于多版本管理,注意是ip-address,早期版本是ipAddress
    14. instance-id: ${spring.cloud.client.ipaddress}:${spring.application.name}:${server.port}:@project.version@
    15. #turbine配置
    16. turbine:
    17. # appCofing配置需要聚合的服务名称,⽐如这⾥聚合⾃动投递微服务的hystrix监控数据
    18. # 如果要聚合多个微服务的监控数据,那么可以使⽤英⽂逗号拼接,⽐如 a,b,c
    19. appConfig: lagou-service-autodeliver
    20. clusterNameExpression: "'default'" # 集群默认名称

    (3)在当前项目启动类上添加注解@EnableTurbine,开启仪表盘以及Turbine聚合

    1. package com.lagou.edu;
    2. import org.springframework.boot.SpringApplication;
    3. import org.springframework.boot.autoconfigure.SpringBootApplication;
    4. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    5. import org.springframework.cloud.netflix.turbine.EnableTurbine;
    6. @SpringBootApplication
    7. @EnableDiscoveryClient
    8. @EnableTurbine // 开启turbine聚合功能
    9. public class HystrixTurbineApplication9001 {
    10. public static void main(String[] args) {
    11. SpringApplication.run(HystrixTurbineApplication9001.class, args);
    12. }
    13. }

    (4)浏览器访问Turbine项目,http://localhost:9001/turbine.stream,就可以看到监控数据了

    我们通过dashboard的页面查看数据更直观,把刚才的地址输入dashboard地址栏 

    监控页面

  • 相关阅读:
    Service层代码单元测试以及单元测试如何Mock
    Java 基础 进程与线程
    字符串——OKR-Periods of Words(kmp求最短相同前后缀或者说求最长循环节)
    旅游网页设计 web前端大作业 全球旅游私人订制 旅游公司网站模板(HTML+CSS+JavaScript)
    PostgreSQL问题记录:column “...“ does not exist
    云服务器ECS_云主机_服务器托管_计算-阿里云
    Mac OS 使用ScreenCaptureKit进行窗口抓取和系统声音抓取
    在CentOS中开启mysql服务
    本地部署开发环境过程和遇到的问题总结
    高级深入--day23
  • 原文地址:https://blog.csdn.net/weixin_52851967/article/details/126461764