当前位置: 首页 > 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 为其他队列名,即可通用化监控。

http://www.xdnf.cn/news/353431.html

相关文章:

  • 富乐德传感技术盘古信息 | 锚定“未来工厂”新坐标,开启传感器制造行业数字化转型新征程
  • IC解析之TPS92682-Q1(汽车LED灯控制IC)
  • 【C/C++】C语⾔内存函数
  • [Errno 122] Disk quota exceeded
  • Linux59 SSH配置前瞻 JumpServer双网卡ping通
  • 金仓数据库永久增量备份技术原理与操作
  • 电商平台如何做好DDoS 攻防战?
  • 物流基础知识-术语 | 医药物流(1)
  • OpenHarmony平台驱动开发(十),MMC
  • k8s监控方案实践(二):集成Alertmanager告警与钉钉Webhook通知
  • C23 与 MISRA C:2025:嵌入式 C 语言的进化之路
  • 4.3【LLaMA-Factory实战】教育大模型:个性化学习路径生成系统全解析
  • 微服务中 本地启动 springboot 无法找到nacos配置 启动报错
  • 第十六章,网络型攻击防范技术
  • Python 常用内置函数详解(十):help()函数——查看对象的帮助信息
  • 【论文阅读27】-TCN–BiLSTM -滑坡预测
  • 从Dockerfile 构建docker镜像——保姆级教程
  • `待办事项css样式
  • electron 结合 react(cra创建的) 创建桌面应用和打包桌面应用
  • 2025年API安全防御全解析:应对DDoS与CC攻击的智能策略
  • rtsp,。。。。
  • 现代框架对SEO的深度影响
  • 【概念解读】开发中遇到的概念阶段
  • RuntimeError: expected scalar type ComplexDouble but found Float
  • 计算机视觉与深度学习 | 视觉+激光雷达+惯惯性SLAM算法汇总(原理,公式,代码)
  • Java中的分布式缓存与Memcached集成实战
  • 电压取样端口静电浪涌防护方案 之6TS Series瞬态抑制器TVS
  • hz2新建Keyword页面
  • 使用 swift 微调 Qwen3-4b 模型
  • 矩阵短剧系统:如何用1个后台管理100+小程序?深度解析多端绑定技术