Skip to content

Latest commit

 

History

History
38 lines (29 loc) · 1.59 KB

README.md

File metadata and controls

38 lines (29 loc) · 1.59 KB

mq-monitor

基于RabbitMQ的消息监控
后续考虑新增一个定时转发消息等功能

MQ队列监控

1.支持跨机器、进程、VH之间的队列监控
2.支持动态自定义消息格式
3.支持动态修改被监控队列阈值
4.支持动态增改监控队列

事前工作:

1.建立数据库:

https://github.com/HeyFL/mq-monitor/blob/MQ_Monitor/connection_factory_setting.sql

2.配置连接信息(connection_factory_setting表):

factory_name mq_address username password virtual_host
gds-wms 127.0.0.1:5672 mq_pds pds_dev gds-wms

3.配置需要监控的队列信息(monitor_queue表)

queue_name factory_name warn_msg_format warn_msg warn_who warn_way warn_threshold
GDS_WMS_DISPATCH_Q_CALLBACK_DEAD gds-wms 1 1 0
GDS_WMS_WMS_Q_TASK_ASYNC_CONSUME_DEAD gds-wms 1 1 0

通过定时调度工具,如xx-job等定时调用:

http://localhost:8080/getAllQueueCurrentInfoWhichBeyondThreshold

可得到告警消息,以及进行告警(告警需要根据自己需求自己扩展):
VH:gds-wms 队列:GDS_WMS_DISPATCH_Q_CALLBACK_DEAD 消息当前消息条数122 超过阈值:0 请及时排查问题
VH:gds-wms 队列:GDS_WMS_WMS_Q_TASK_ASYNC_CONSUME_DEAD 消息当前消息条数7 超过阈值:0 请及时排查问题
VH:gds-wos-uspdxa 队列:GDS_WMS_WOS_Q_JOB_FORECAST_DEAD 消息当前消息条数6 超过阈值:0 请及时排查问题
VH:gds-wms 队列:GDS_WOS_WMS_Q_CALLBACK_DEAD 消息当前消息条数49 超过阈值:0 请及时排查问题