前面我們介紹了通過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的監控數據，案例成功！

總結

以上是生活随笔為你收集整理的java监控rabbitMq服务状态,SpringCloud-Turbine【RabbitMQ服务监控】的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。