前面我们介绍了通过turbine直接聚合多个服务的监控信息，实现了服务的监控，但是这种方式有个不太好的地方就是turbine和服务的耦合性太强了，针对这个问题，我们可以将服务的监控消息发送到RabbitMQ中，然后turbine中RabbitMQ中获取获取监控消息，这样就实现类服务和turbine的解耦。
我们通过案例来演示下如何实现该效果
一、启动RabbitMQ服务
显然我们需要安装启动一个RabbitMQ服务
在这里插入图片描述
二、创建consumer服务
创建一个consumer服务，同时要将dashboard的监控信息发送到RabbitMQ服务中。
1.创建项目
在这里插入图片描述
2.添加依赖
此处的核心依赖如下，完整依赖参考git完整代码
org.springframework.boot
spring-boot-starter-actuator
org.springframework.cloud
spring-cloud-starter-hystrix
1.3.2.RELEASE
org.springframework.cloud
spring-cloud-starter-hystrix-dashboard
org.springframework.cloud
spring-cloud-netflix-hystrix-stream
org.springframework.cloud
spring-cloud-starter-stream-rabbit
3.修改配置
添加对RabbitMQ的配置信息
spring.application.name=shop-product-consumer-hystrix-dashboard
server.port=9090
#设置服务注册中心地址，指向另一个注册中心
eureka.client.serviceUrl.defaultZone=http://dpb:123456@eureka1:8761/eureka/,http://dpb:123456@eureka2:8761/eureka/
#Feign 默认是不开启 Hystrix 的。默认为：false
feign.hystrix.enabled=true
spring.rabbitmq.host=192.168.88.150
spring.rabbitmq.port=5672
spring.rabbitmq.username=dpb
spring.rabbitmq.password=123
spring.rabbitmq.virtualHost=/
4.修改启动类
启动服务，并访问测试
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
@EnableHystrix
@EnableHystrixDashboard
public class SpringcloudFeignProdcutConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(SpringcloudFeignProdcutConsumerApplication.class, args);
}
}
在这里插入图片描述
在这里插入图片描述
同时注意RabbitMQ的控制台
在这里插入图片描述
能够看到是有变化的
三、创建turbine服务
1.创建项目
在这里插入图片描述
2.添加依赖
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-starter-test
test
org.springframework.cloud
spring-cloud-starter-config
org.springframework.cloud
spring-cloud-starter-turbine-stream
org.springframework.cloud
spring-cloud-starter-stream-rabbit
3.修改配置
spring.application.name=shop-product-consumer-turbine
server.port=1002
#设置服务注册中心地址，指向另一个注册中心
eureka.client.serviceUrl.defaultZone=http://dpb:123456@eureka1:8761/eureka/,http://dpb:123456@eureka2:8761/eureka/
spring.rabbitmq.host=192.168.88.150
spring.rabbitmq.port=5672
spring.rabbitmq.username=dpb
spring.rabbitmq.password=123
spring.rabbitmq.virtualHost=/
4.启动类
注意注解
@SpringBootApplication
@EnableTurbineStream
public class SpringcloudFeignProdcutConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(SpringcloudFeignProdcutConsumerApplication.class, args);
}
}
启动服务
在这里插入图片描述
说明从RabbitMQ中获取到了监控数据
四、创建dashboard可视服务
可视化的服务可以用之前创建的
在这里插入图片描述
即可
在这里插入图片描述
在这里插入图片描述
看到了consumer的监控数据，案例成功！
