微服务spring cloud-使用Turbine聚合监控数据

分手后的思念是犯贱 2022-04-18 01:52 399阅读 0赞

# 使用Turbine聚合监控数据 #

使用/hystrix.stream端点监控单个微服务实例。然而，使用微服务架构的应用系统一般会  
包含若干个微服务，每个微服务通常都会部署多个实例。如果每次只能查看单个实例的监控  
数据，就必须在Hystrix Dashboard上切换想要监控的地址，这显然很不方便。如何解决该问题呢？

# Turbine简介 #

Turbine是一个聚合Hystrix监控数据的工具，他可以将所有相关/hystrix.stream端点的数据聚合  
到一个组合的道一个组合的/turbine.streeam中，从而让集群的监控更加方便。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70]

# 使用Turbine监控多个微服务 #

### 1.为了让Turbine监控两个以上的微服务，现将项目microservice-consumer-movie-feign- ###

hystrix-fallback-stream的application.yml改成如下内容：

server:
        port: 8020                  #端口号
    spring:
        application:
            name: movie-feign-hystrixstream     #服务名称
    eureka:
        instance:
             prefer-ip-address: true
        client:
            serviceUrl:
                defaultZone: http://localhost:8761/eureka/

### 2.创建一个Maven项目,ArtifactId是 ###

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-netflix-turbine</artifactId>
                <version>2.0.2.RELEASE</version>
            </dependency>

### 3.在启动类上添加@EnableTurbine ###

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

### 4.编写配置文件application.yml ###

server:
        port: 8031
    spring:
        application:
            name: turbine
    eureka:
        client:
            service-url:
                defaultZone: http://localhost:8761/eureka
        instance:
            prefer-ip-address: true
    turbine:
        app-config: movie-hystrix,movie-feign-hystrixstream
        cluster-name-expression: new String('default')
        combine-host-port: true
        instanceUrlSuffix: /actuator/hystrix.stream

使用以上配置，Turbine会在Eureka Server中找到movie-hystrix、movie-feign-hystrixstream这两个微服务，并聚合两个微服务的监控数据。

### 5.测试 ###

1.启动项目microservice-discovery-eureka。  
2.启动项目microservice-provider-user。  
3.启动项目microservice-consumer-movie-ribbon-hystrix。  
4.启动项目microservice-consumer-movie-feign-hystrix-fallback-stream。  
5.启动项目microservice-hystrix-turbine。  
6.启动microservice-hystrix-dashboard。  
7.访问http://localhost:8010/user1，让microservice-consumer-movie-ribbon-hystrix微服务产生监控数据  
8.访问http://localhost:8020/user1，让microservice-consumer-movie-feign-hystrix-fallback-stream微服务产生监控数据  
9.打开Hystrix Dashboarad首页http://localhost:8030/hystrix.stream，在URL一栏填入http://localhost:8031/turbine.stream,随意指定一个Title并点击Monitor Stream按钮。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70 1]

# 使用消息中间件收集数据 #

### 先安装ERlang，再安装RabbitMQ ###

#### 操作流程参考：[https://www.cnblogs.com/shanyou/p/4067250.html][https_www.cnblogs.com_shanyou_p_4067250.html] ####

## 修改微服务 ##

1.复制项目microservice-consumer-movie-ribbon-hystrix，将ArtifactId修改为microservice-consumer-movie-ribbon-hystrix-turbine-mq。  
2.添加以下依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
                <version>2.0.1.RELEASE</version>
            </dependency>

3.在配置文件application.yml中添加如下内容，连接RabbitMQ。

spring:
    	rabbitmq:
        	host: localhost
            port: 5672
            username: guest
            password:  guest

这样微服务就改造完成了

# 改造Turbine #

1.复制microservice-hystrix-turbine，将ArtifactId修改为microservice-hystrix-turbine-mq。  
2.在pom.xml添加

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-turbine-stream</artifactId>
            </dependency>
    
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
            </dependency>

同时，删除

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <<artifactId>spring-cloud-netflix-turbine</artifactId>
    </dependency>

3.修改启动类，把@EnableTurbine修改为@EnableTurbineStream。  
4.修改配置文件application.yml,添加如下内容。

spring:
    	rabbitmq:
        	host: localhost
            port: 5672
            username: guest
            password:  guest

同时删除：

turbine:
        app-config: movie-hystrix,movie-feign-hystrixstream
        cluster-name-expression: new String('default')

5.测试  
启动项目microservice-discovery-eureka。  
启动项目microservice-provider-user。  
启动项目microservice-consumer-movie-ribbon-hystrix-turbine-mq.  
启动项目microservice-hystrix-turbine-mq。  
访问http://localhot:8010/user/1，可获得正常结果。  
访问http://localhost:8031,会发现Turbine能持续不断的显示监控数据

## 注意点 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70 2]

本文大部分内容转载自周立的《Spring Cloud与Docker微服务架构实战》

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70]: /images/20220418/623edf75b82f4d4aa468a99b4b8f5428.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70 1]: /images/20220418/b066ed3590d0400d9f291a08634c413a.png
[https_www.cnblogs.com_shanyou_p_4067250.html]: https://www.cnblogs.com/shanyou/p/4067250.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzQzOTQ5NA_size_16_color_FFFFFF_t_70 2]: /images/20220418/22146988102e4dbcaec031e4df811867.png