当前位置: 首页 > news >正文

Zabbix监控 RabbitMQ 指定消息队列名称(pull_alarms )的消费者

✅ 1. 编写 RabbitMQ 队列监控脚本

创建脚本文件 /usr/local/bin/zbx_rabbitmq_metric.sh 并写入以下内容:

#!/bin/bash
# /usr/local/bin/zbx_rabbitmq_metric.shQUEUE=$1
METRIC=$2
USER=$3
PASS=$4if [[ -z "$QUEUE" || -z "$METRIC" || -z "$USER" || -z "$PASS" ]]; thenecho "Missing arguments"exit 1
fi# URL encode queue name
ENCODED_QUEUE=$(printf %s "$QUEUE" | jq -s -R -r @uri)# 调用 RabbitMQ API(注意修改虚拟主机名 prod_kac_saas)
API_URL="http://localhost:15672/api/queues/prod_kac_saas/${ENCODED_QUEUE}"
RESPONSE=$(curl -s -u "$USER:$PASS" "$API_URL")# 提取目标字段值
VALUE=$(echo "$RESPONSE" | jq -r ".$METRIC")# 处理空值
if [[ "$VALUE" == "null" || -z "$VALUE" ]]; thenecho 0
elseecho "$VALUE"
fi

设置执行权限:

chmod +x /usr/local/bin/zbx_rabbitmq_metric.sh

✅ 2. Zabbix Agent 配置

编辑 /etc/zabbix/zabbix_agentd.d/rabbitmq.conf 文件,加入以下内容:

UserParameter=rabbitmq.queue.metric[*],/usr/local/bin/zbx_rabbitmq_metric.sh "$1" "$2" "$3" "$4"

然后重启 Zabbix Agent:

systemctl restart zabbix-agent

✅ 3. Zabbix Web 配置

✅ 添加宏(Template 或 Host 层级)

前往 Zabbix Web → Configuration → Templates (或 Hosts),找到应用的模板或主机,添加以下宏:

宏名称宏值
{$RABBITMQ.API.USER}RabbitMQ 的用户名
{$RABBITMQ.API.PASSWORD}RabbitMQ 的密码

✅ 添加监控项(Item)

  • 名称pull_alarms: Consumers

  • 键值

    rabbitmq.queue.metric[pull_alarms,consumers,{$RABBITMQ.API.USER},{$RABBITMQ.API.PASSWORD}]
    
  • 类型:Zabbix agent

  • 数据类型:Numeric (unsigned)

  • 更新间隔:30s 或其他合适间隔

  • 单位:个


✅ 可选:添加图形 (Graph)

你可以为该监控项添加图形,例如:

  • 图形名称pull_alarms: Number of consumers

  • Y轴单位:Consumers

  • 添加 Item:上面创建的监控项


✅ 4. 验证监控效果

执行测试命令检查是否返回消费者数量:

zabbix_agentd -t 'rabbitmq.queue.metric[pull_alarms,consumers,admin,password]'

若输出非 0,表示监控脚本正常工作,Zabbix 也可采集到该指标。


📌 总结

  • 监控方式:Zabbix agent + RabbitMQ HTTP API。

  • 核心指标:队列 pull_alarms 的消费者数量。

  • 扩展:只需替换 pull_alarms 为其他队列名,即可通用化监控。

相关文章:

  • 房产销售系统设计与实现(Spring Boot + Vue 前后端分离)
  • 科技创业园共享会议室线上预约及智能密码锁系统搭建指南
  • 豆包:基于多模态交互的智能心理咨询机器人系统设计与效果评估——情感计算框架下的对话机制创新
  • 深入理解主从数据库架构与主从复制
  • 如何使用测试软件 Jmeter
  • 项目高压生存指南:科学重构身体与认知系统的抗压算法
  • 数巅智能携手北京昇腾创新中心深耕行业大模型应用
  • 【MySQL数据库】--SQLyog创建数据库+python连接
  • 基于公共卫生大数据收集与智能整合AI平台构建测试:从概念到实践
  • 神经元和神经网络定义
  • HTML应用指南:利用POST请求获取全国德邦快递服务网点位置信息
  • Vue项目---懒加载的应用
  • xxl-job的pg数据库改造适配
  • 【一】浏览器的copy as fetch和copy as bash的区别
  • Android kernel日志中healthd关键词意义
  • 【linux常用命令】处理失效链接
  • 【PostgreSQL数据分析实战:从数据清洗到可视化全流程】电商数据分析案例-9.4 可视化报告输出
  • 全球首款无限时长电影生成模型SkyReels-V2本地部署教程:视频时长无限制!
  • js原型污染 + xss劫持base -- no-code b01lersctf 2025
  • 单片机-STM32部分:9-1、触控检测芯片
  • 中国一重集团有限公司副总经理陆文俊被查
  • 上海:企业招用高校毕业生可享受1500元/人一次性扩岗补助
  • 海关总署统计分析司司长:4月进出口增速较一季度加快4.3个百分点
  • 江苏淮安优化村级资源配置:淮安区多个空心村拟并入邻村
  • 李云泽:支持设立新的金融资产投资公司,今天即将批复一家
  • 加拿大总理访美与特朗普“礼貌交火”