SpringCloud四:监控数据聚合Turbine+RabbitMQ

小咪咪 2022-05-15 05:57 368阅读 0赞

之前的文章中说到,消费者把服务容错日志发布到RabbitMQ中,  
[SpringCloud之消费者架构Eureka+Ribbon+Feign+Hystrix+Sleuth+RabbitMQ][SpringCloud_Eureka_Ribbon_Feign_Hystrix_Sleuth_RabbitMQ]  
通过Turbine把多个consumer聚集起来,交到Hystrix-Dashboard的面板中分析,Hystrix-Dashboard文章如下  
[SpringCloud之监控面板Hystrix-Dashboard][SpringCloud_Hystrix-Dashboard]  
本文阐述Turbine+RabbitMQ的设计

在pom.xml添加依赖,还是老话,  
SpringBoot的版本为1.5.15  
SpringCloud的版本为Edgware.SR4

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-actuator</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-eureka</artifactId>
    		</dependency>
    		
    	<dependency>
    		<groupId>org.springframework.cloud</groupId>
    		<artifactId>spring-cloud-starter-turbine-amqp</artifactId>
    	</dependency>

在application.yml中配置如下,如果想把Turbine注册到eureka中,你会发现之前的方式不起作用,原因如下:  
在spring-cloud-turbine-stream ，该依赖会启动一个Netty容器，并将server.port 设为-1 ，从而关闭Servlet容器。这其实是官方的一个小Bug，不过官方说等Spring Boot 2.0才会修复，  
详见：[https://github.com/spring-cloud/spring-cloud-netflix/issues/1774][https_github.com_spring-cloud_spring-cloud-netflix_issues_1774]  
解决方法:  
在指定server.port 的基础上，指定management.port ，两个端口务必不同；  
添加配置：eureka.instance.non-secure-port ，以便于服务注册到Eureka Server上，该端口需要跟server.port 所配置的端口一致

spring:
      application:
        name: turbine
      rabbitmq:
        host: 120.77.245.104
        port: 5672
        username: guest
        password: guest
    server:
      port: 10001
    eureka:
      instance:
        prefer-ip-address: true
        instance-id: turbine:10001
        non-secure-port: 10001
      client:
        service-url:
          defaultZone: http://localhost:7001/eureka/ 
    management:
      port: 10011

在启动类中,由于使用Turbine+RabbitMQ,使用@EnableTurbineStream开启

@EnableTurbineStream @EnableDiscoveryClient @SpringBootApplication public class TurbineApplication { // http://localhost:10001/turbine.stream // : ping // data: // {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1535162983275} public static void main(String[] args) { SpringApplication.run(TurbineApplication.class, args); } }

[SpringCloud_Eureka_Ribbon_Feign_Hystrix_Sleuth_RabbitMQ]: https://blog.csdn.net/lhc0512/article/details/82053419
[SpringCloud_Hystrix-Dashboard]: https://blog.csdn.net/lhc0512/article/details/82054409
[https_github.com_spring-cloud_spring-cloud-netflix_issues_1774]: https://github.com/spring-cloud/spring-cloud-netflix/issues/1774