SpringCloud学习笔记（十二、断路器监控）

前面讲解了断路器，当数据服务不可用的时候，断路器就会发挥作用。

那么数据服务什么时候可用，什么时候不可用，如何监控这个事情呢？我们就要用到断路器监控来可视化掌控这个情况。

创建监控子项目

创建子项目hystrix-dashboard 。

pom.xml

<?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>edu.hpu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>hystrix-dashboard</artifactId>

    <name>hystrix-dashboard</name>
    <!-- FIXME change it to the project's website -->
    <url>http://www.example.com</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
    </properties>

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

断路器监控启动类

ProductServiceHystrixDashboardApplication，主要就是这个注解@EnableHystrixDashboard，表示开启仪表盘功能。

package edu.hpu.springcloud;

import cn.hutool.core.util.NetUtil;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;

@SpringBootApplication
@EnableHystrixDashboard
public class ProductServiceHystrixDashboardApplication {
    public static void main(String[] args) {
        int port = 8020;
        if(!NetUtil.isUsableLocalPort(port)) {
            System.err.printf("端口%d被占用了，无法启动%n", port );
            System.exit(1);
        }
        new SpringApplicationBuilder(ProductServiceHystrixDashboardApplication.class).properties("server.port=" + port).run(args);

    }
}

application.yml

spring:
  application:
    name: hystrix-dashboard

ProductViewServiceFeignApplication

修改视图微服务，主要是在启动类中添加注解@EnableCircuitBreaker，使其可以把消息发送给监控中心。

package edu.hpu.springcloud;

import brave.sampler.Sampler;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.NetUtil;
import cn.hutool.core.util.NumberUtil;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;

import java.util.Scanner;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
@EnableFeignClients
@EnableCircuitBreaker
public class ProductViewServiceFeignApplication {
    public static void main(String[] args) {
        //判断 rabiitMQ 是否启动
        int rabbitMQPort = 5672;
        if(NetUtil.isUsableLocalPort(rabbitMQPort)) {
            System.err.printf("未在端口%d 发现 rabbitMQ服务，请检查rabbitMQ 是否启动", rabbitMQPort );
            System.exit(1);
        }
        int port = 0;
        int defaultPort = 8012;
        Future<Integer> future = ThreadUtil.execAsync(() ->{
            int p = 0;
            System.out.println("请于5秒钟内输入端口号, 推荐  8012 、 8013  或者  8014，超过5秒将默认使用"+defaultPort);
            Scanner scanner = new Scanner(System.in);
            while(true) {
                String strPort = scanner.nextLine();
                if(!NumberUtil.isInteger(strPort)) {
                    System.err.println("只能是数字");
                    continue;
                }
                else {
                    p = Convert.toInt(strPort);
                    scanner.close();
                    break;
                }
            }
            return p;
        });
        try{
            port=future.get(5, TimeUnit.SECONDS);
        }
        catch (InterruptedException | ExecutionException | TimeoutException e){
            port = defaultPort;
        }
        if(!NetUtil.isUsableLocalPort(port)) {
            System.err.printf("端口%d被占用了，无法启动%n", port );
            System.exit(1);
        }
        new SpringApplicationBuilder(ProductViewServiceFeignApplication.class).properties("server.port=" + port).run(args);

    }
    @Bean
    public Sampler defaultSampler() {
        return Sampler.ALWAYS_SAMPLE;
    }
}

AccessViewService

这是一个工具类，不停地访问视图微服务，方便监控。

package edu.hpu.springcloud.util;

import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.http.HttpUtil;

public class AccessViewService {
    public static void main(String[] args) {

        while(true) {
            ThreadUtil.sleep(1000);
            try {
                String html= HttpUtil.get("http://127.0.0.1:8012/products");
                System.out.println("html length:" + html.length());
            }
            catch(Exception e) {
                System.err.println(e.getMessage());
            }

        }

    }
}

启动访问：

依次启动服务中心、配置服务器、数据微服务、视图微服务、断路器监控。

运行访问工具类，以不停访问视图微服务。

访问地址：

http://localhost:8020/hystrix

这个是监控地址，

在第一个输入框输入：

http://localhost:8012/actuator/hystrix.stream

这个地址就是视图微服务的短路信息。

然后点击 Monitor Stream 就可以看到监控信息了。

监控图详解：

结束数据服务：

红色的数据就达到 100%。

问题

1、怎么结束服务？

上面一步操作是结束数据服务，我用的办法是先查端口，再在任务管理器中结束进程，这种方式太笨重，查了一下，没有找到特别理想的结果。

看参考【3】吧。

参考：

【1】、

http://how2j.cn/k/springcloud/springcloud-dashboard/2043.html#nowhere

【2】、

https://wangsong.blog.csdn.net/article/details/78224483

【3】、

http://www.itmuch.com/spring-cloud-sum/how-to-unregister-service-in-eureka/

SpringCloud学习笔记（十二、断路器监控）

创建监控子项目

pom.xml

断路器监控启动类

application.yml

ProductViewServiceFeignApplication

AccessViewService

启动访问：

问题

继续阅读

Spring Cloud Learning | 第四篇：声明式服务调用（Fegin）

记录在华为云服务器上使用Docker启动最新版本Minio文件服务器遇到的问题

springboot 构建 spring cloud 微服务项目搭建ARTHUR框架分享

从产品经理的角度如何提升项目的交付质量？

分布式幂等问题解决方案三部曲纲要一背景二什么是幂等三解决方案三部曲四总结

别轻易转数据分析了！太卷了

如何优雅的创建init.py文件？

微服务架构专题十：Spring-Cloud 之 config 分布式配置中心

POPUP_TO_DECIDE_LIST 弹出选择框_SAP刘梦_新浪博客

springcloud-config配置中心分布式管理

spring cloud备忘笔记-7-分布式配置中心（Spring Cloud Config）

SpringCloud实战之路 | 应用篇（七）分布式配置中心Spring Cloud Config+Bus

从零开始搭建微服务：跨域处理

谷粒商城：认证服务准备+60s短信验证

cron 表达式解读

微服务-性能压测\缓存redis和分布式锁redisson和SpringCache