springcloud-dashboard流监控实现

ゞ浴缸里的玫瑰 2022-11-05 08:32 60阅读 0赞

### springcloud-dashboard流监控实现 ###

*   *  1、新建一个maven项目作为dashboard的单独项目
     *   *  1. 编写pom文件
         *  2. 编写配置
         *  3. 编写启动类
         *  4. 测试
     *  2、修改服务熔断提供者的代码
     *   *  1. 添加依赖
         *  2. 添加一个Bean
         *  3. 测试

有时候，我们需要监控我们的服务，这时候就要用到流监控了  
我们在这篇文章的基础上完成

> https://blog.csdn.net/weixin\_43520670/article/details/114333758

## 1、新建一个maven项目作为dashboard的单独项目 ##

### 1. 编写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">
        <parent>
            <artifactId>springcloud</artifactId>
            <groupId>org.example</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>springcloud-consumer-hystrix-dashboard</artifactId>
        <dependencies>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-ribbon</artifactId>
                <version>1.4.6.RELEASE</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix</artifactId>
                <version>1.4.6.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
                <version>1.4.6.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
                <version>1.4.6.RELEASE</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.example</groupId>
                <artifactId>springcloud-api</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
    
        </dependencies>
    
    </project>

### 2. 编写配置 ###

server:
      port: 9001
    
    spring:
      datasource:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/mybatis_plus?serverTimezone=GMT%2B8
        username: root
        password: 520China

### 3. 编写启动类 ###

主要是加入@EnableHystrixDashboard 开启监控

package com.hzxy.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
    
    @SpringBootApplication
    @EnableHystrixDashboard  //开启监控
    public class UserConsumerDashboard_9001 { 
        public static void main(String[] args) { 
            SpringApplication.run(UserConsumerDashboard_9001.class,args);
        }
    }

### 4. 测试 ###

在浏览器访问 http://ybg.eureka1.com:9001/hystrix，出现如下界面，启动成功！  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70]

## 2、修改服务熔断提供者的代码 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 1]

### 1. 添加依赖 ###

要添加actuator监控依赖

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>

### 2. 添加一个Bean ###

要在springcloud注册一个Servlet

//增加一个Servlet
        @Bean
        public ServletRegistrationBean hystrixMetricsStreamServlet(){ 
            ServletRegistrationBean registrationBean = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
            registrationBean.addUrlMappings("/actuator/hystrix.stream");
            return registrationBean;
        }

完整代码如下：

package com.hzxy.springcloud;
    
    import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.web.servlet.ServletRegistrationBean;
    import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.context.annotation.Bean;
    
    @MapperScan("com.hzxy.springcloud.mapper")
    @EnableDiscoveryClient       //服务发现
    @EnableEurekaClient      //在服务启动后自动注册到Eureka中
    @SpringBootApplication
    @EnableCircuitBreaker     //添加对熔断的支持
    public class HystrixProvider_8001 { 
        public static void main(String[] args) { 
            SpringApplication.run(HystrixProvider_8001.class,args);
        }
    
        //增加一个Servlet
        @Bean
        public ServletRegistrationBean hystrixMetricsStreamServlet(){ 
            ServletRegistrationBean registrationBean = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
            registrationBean.addUrlMappings("/actuator/hystrix.stream");
            return registrationBean;
        }
    }

### 3. 测试 ###

开启注册中心，服务提供者和监控模块，然后在监控模块输入我们注册的url和其它参数，然后点击下方按钮  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 2]  
然后可以看到  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 3]  
我们访问注册了熔断的url可以看到数据变化  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 4]

**注意事项：我在做这个的时候遇到了一个问题，就是点击那个按钮后，它一直处于加载中，原因是我没有访问注册了熔断的url，它监控不到**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70]: /images/20221023/23bc91c7cc764a11ad5f5e4aa19ee1b5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 1]: /images/20221023/14c73407a45e4ecbb7488d436f1a52b2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 2]: /images/20221023/b2e4c839856e452ab3b52e5597b91096.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 3]: /images/20221023/c00430919d3c4356bd2723f3f81ba1a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70 4]: /images/20221023/b860546eac344f94b745b044a012fe07.png