Debian消息队列监控可从系统日志、消息队列工具及第三方平台入手,具体方法如下:
journalctl查看系统级消息队列日志(如RabbitMQ、Kafka服务日志):sudo journalctl -u rabbitmq-server -f # 监控RabbitMQ服务日志
sudo journalctl -u kafka -f # 监控Kafka服务日志
rabbitmq-plugins enable rabbitmq_management # 启用插件
访问 http://localhost:15672 查看监控数据
kafka-topics.sh --list --bootstrap-server localhost:9092 # 列出主题
kafka-consumer-groups.sh --describe --group my-group --bootstrap-server localhost:9092 # 查看消费者组详情
#!/bin/bash
QUEUE_LENGTH=$(rabbitmqctl list_queues | grep "my_queue" | awk '{print $2}')
if [ "$QUEUE_LENGTH" -gt 1000 ]; then
echo "队列积压告警!当前长度:$QUEUE_LENGTH" | mail -s "RabbitMQ Alert" admin@example.com
fi
参考来源: