【愚公系列】2023年11月 Java教学课程 193-SpringCloud（Hystrix服务监控）

愚公搬代码

发布于 2025-06-02 14:48:59

8800

代码可运行

文章被收录于专栏：历史专栏历史专栏

运行总次数：0

代码可运行

🚀前言

微服务架构中的服务监控是非常重要的一环，它可以帮助我们保持系统的稳定性、可用性和性能。服务监控主要包括以下几个方面：

健康检查：每个微服务都需要提供一个健康检查接口，用于检查其是否正常运行。通常可以通过HTTP请求或者TCP连接来检查服务的健康状态。
日志监控：日志监控能够帮助我们实时监控日志信息，以便及时发现系统中的异常情况。通常采用ELK等日志收集和分析系统来实现。
指标监控：指标监控是实时监控系统各种性能指标的一种方式，可以帮助我们及时发现系统中的性能瓶颈和问题。常用的指标包括CPU使用率、内存使用率、网络IO等。
追踪监控：追踪监控是一种跟踪系统请求执行过程的监控方式，可以用于找出请求执行过程中的瓶颈和问题。通常采用Jaeger等分布式追踪系统来实现。

服务监控是微服务架构中非常重要的一环，我们需要对各个微服务进行全面的监控，以保证系统的稳定性、可用性和性能。

🚀一、Hystrix服务监控

Hystrix 是 Netflix 开源的一个高可用的熔断器实现，它可以自动地监控调用链路中的各个微服务之间的异常情况，一旦发生异常情况，Hystrix 会自动地熔断该微服务调用，防止该调用继续扩散到整个应用程序中。Hystrix 提供了一些监控指标，可以帮助开发人员了解应用程序的运行情况，例如：

请求的总数、失败数、成功数等；
熔断器状态，包括开关状态、熔断时间等；
每个服务的健康状况，包括响应时间、QPS 等。

Hystrix 还提供了一个可视化的监控仪表板，可以在 web 界面上直观地查看应用程序的运行情况，并且可以方便地进行调试和故障排查。通过 Hystrix 的监控和熔断功能，可以大大提高应用程序的可用性和容错性，确保应用程序的稳定运行。

Turbine 可以将多个 Hystrix-dashboard 实例的监控数据聚合起来，方便进行统一的监控和管理。通过配置 Turbine 与 Eureka 注册中心的连接，可以自动发现并收集所有微服务实例的监控数据，然后在 Turbine 的监控面板上进行展示和分析。这样就可以方便的进行微服务整体的监控和管理了。

🔎1.Turbine聚合监控

🦋1.1 搭建监控模块

1. 创建监控模块

创建hystrix-monitor模块，使用Turbine聚合监控多个Hystrix dashboard功能,

2. 引入Turbine聚合监控起步依赖

在 Spring Boot 项目中，需要在 pom.xml 文件中引入 Turbine 和 Hystrix Dashboard 的依赖，比如：

<?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">
    <parent>
        <artifactId>hystrix-parent</artifactId>
        <groupId>com.itheima</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>hystrix-monitor</artifactId>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <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-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-netflix-eureka-client</artifactId>
        </dependency>


        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

3. 修改application.yml

在 Spring Boot 项目中，需要在 pom.xml 文件中引入 Turbine 和 Hystrix Dashboard 的依赖，比如：

spring:
  application.name: hystrix-monitor
server:
  port: 8769
turbine:
  combine-host-port: true
  # 配置需要监控的服务名称列表
  app-config: hystrix-provider,hystrix-consumer
  cluster-name-expression: "'default'"
  aggregator:
    cluster-config: default
  #instanceUrlSuffix: /actuator/hystrix.stream
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

其中，clusterConfig 和 clusterNameExpression 表示聚合多个 Hystrix Dashboard 的配置信息。appConfig 表示要聚合的 Hystrix Dashboard 的应用名称列表。instanceUrlSuffix 表示 Hystrix Dashboard 的监控数据 URL 后缀。在这个示例中，turbine 服务会聚合名为 hystrix-provider、hystrix-consumer 的二个微服务的 Hystrix Dashboard 数据，并将聚合后的数据注册到 Eureka 服务器中。

4. 创建启动类

在 Spring Boot 项目中，需要在 pom.xml 文件中引入 Turbine 和 Hystrix Dashboard 的依赖，比如：

@SpringBootApplication
@EnableEurekaClient

@EnableTurbine //开启Turbine 很聚合监控功能
@EnableHystrixDashboard //开启Hystrix仪表盘监控功能
public class HystrixMonitorApp {

    public static void main(String[] args) {
        SpringApplication.run(HystrixMonitorApp.class, args);
    }

}

🦋1.2 修改被监控模块

需要分别修改 hystrix-provider 和 hystrix-consumer 模块：

1、导入依赖：

<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-hystrix-dashboard</artifactId>
</dependency>

2、配置Bean

此处为了方便，将其配置在启动类中。

@Bean
    public ServletRegistrationBean getServlet() {
        HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
        ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
        registrationBean.setLoadOnStartup(1);
        registrationBean.addUrlMappings("/actuator/hystrix.stream");
        registrationBean.setName("HystrixMetricsStreamServlet");
        return registrationBean;
    }

3、启动类上添加注解@EnableHystrixDashboard

@EnableDiscoveryClient
@EnableEurekaClient
@SpringBootApplication
@EnableFeignClients 
@EnableHystrixDashboard // 开启Hystrix仪表盘监控功能
public class ConsumerApp {


    public static void main(String[] args) {
        SpringApplication.run(ConsumerApp.class,args);
    }
    @Bean
    public ServletRegistrationBean getServlet() {
        HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
        ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
        registrationBean.setLoadOnStartup(1);
        registrationBean.addUrlMappings("/actuator/hystrix.stream");
        registrationBean.setName("HystrixMetricsStreamServlet");
        return registrationBean;
    }
}