SpringCloud——断路器聚合监控

101 阅读 0 评论 67 点赞

我是靠谱客的博主斯文电脑，这篇文章主要介绍SpringCloud——断路器聚合监控，现在分享给大家，希望可以做个参考。

SpringCloud学习
1.IDEA创建父子项目
2.SpringCloud——Eureka
3.SpringCloud——注册服务
4.SpringCloud——获取服务(1.Ribbon)
5.SpringCloud——获取服务(1.Feign)
6.SpringCloud——服务链路追踪
7.SpringCloud——断路器
8.SpringCloud——断路器监控
9.SpringCloud——断路器聚合监控
10.SpringCloud——网关

1.为什么要使用断路器聚合监控

在上个知识点讲解了针对一个微服务的断路器监控，但是微服务通常会是多个实例组成的一个集群。
倘若集群里的实例比较多，难道要挨个挨个去监控这些实例吗？何况有时候，根据集群的需要，会动态增加或者减少实例，监控起来就更麻烦了。
所以为了方便监控集群里的多个实例，springCloud 提供了一个 turbine 项目，它的作用是把一个集群里的多个实例汇聚在一个
turbine里，这个然后再在断路器监控里查看这个 turbine, 这样就能够在集群层面进行监控啦。

2.创建子项目trubine
https://blog.csdn.net/m0_45025658/article/details/106433731

3.pom.xml

复制代码

<?xml version="1.0" encoding="UTF-8"?>

<parent>
    <groupId>org.example</groupId>
    <artifactId>SpringCloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>

<artifactId>trubine</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>trubine</name>

<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>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-turbine</artifactId>
    </dependency>
  </dependencies>
</project>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
<?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">
  <modelVersion>4.0.0</modelVersion>

  <parent>
    <groupId>org.example</groupId>
    <artifactId>SpringCloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>

  <artifactId>trubine</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>trubine</name>

  <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>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-turbine</artifactId>
    </dependency>
  </dependencies>
</project>

4.TurbineApplication

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
package org.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.turbine.EnableTurbine;

@SpringBootApplication
@EnableTurbine
public class TurbineApplication {
    public static void main( String[] args ) {
        new SpringApplication(TurbineApplication.class).run(args);
    }
}

5.application.yml

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
spring:
  application.name: turbine
turbine:
  aggregator:
    clusterConfig: default
  appConfig: product-view-service-feign
  clusterNameExpression: new String("default")
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
      
server:
  port: 8009

6.在feign-service中新建一个AccessViewService_2

同时监控不同的端口（8004，8007）

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
package org.example.service;

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

class AccessViewService_2 {

    public static void main(String[] args) {

        while(true) {
            ThreadUtil.sleep(1000);
            access(8004);
            access(8007);
        }

    }

    public static void access(int port) {
        try {
            String html= HttpUtil.get(String.format("http://127.0.0.1:%d/products",port));
            System.out.printf("%d 地址的视图服务访问成功，返回大小是 %d%n" ,port, html.length());
        }
        catch(Exception e) {
            System.err.printf("%d 地址的视图服务无法访问%n",port);
        }
    }
}