Idle:通過自動發現隊列，獲取各個隊列中的ready,unackd等值
sudo !!!
1 #!/bin/sh 2 discovery(){ 3 Queue=(`rabbitmqctl list_queues |grep -v List |awk '{print $1}'`) 4 len=${#Queue[@]} 5 printf "{\n" 6 printf '\t'"\"data\":[" 7 for ((i=0;i<$len;i++)) 8 do 9 printf '\n\t\t{' 10 printf "\"{#MQ_NAME}\":\"${Queue[$i]}\"}" 11 if [ $i -lt $[$len-1] ];then 12 printf ',' 13 fi 14 done 15 printf "\n\t]\n" 16 printf "}\n" 17 18 } 19
20 21 22 messages(){ 23 QUEUE=$1 24 ROW=`rabbitmqctl list_queues |grep -n $QUEUE |awk -F : '{print $1}'` 25 MESSAGES=`rabbitmqctl list_queues messages |awk 'NR=="'''$ROW'''"{print}'` 26 echo $MESSAGES 27 } 28 ready(){ 29 QUEUE=$1 30 ROW=`rabbitmqctl list_queues |grep -n $QUEUE |awk -F : '{print $1}'` 31 READY=`rabbitmqctl list_queues messages_ready |awk 'NR=="'''$ROW'''"{print}'` 32 echo $READY 33 } 34 unack(){ 35 QUEUE=$1 36 ROW=`rabbitmqctl list_queues |grep -n $QUEUE |awk -F : '{print $1}'` 37 UNACK=`rabbitmqctl list_queues messages_unacknowledged |awk 'NR=="'''$ROW'''"{print}'` 38 echo $UNACK 39 } 40 41 42 if [ $1 == "discovery" ]; then 43 discovery 44 elif [ $1 == "messages" ]; then 45 messages $2 46 elif [ $1 == "ready" ]; then 47 ready $2 48 elif [ $1 == "unack" ]; then 49 unack $2 50 fi
1 UserParameter=rabbitmq.discovery_queue[*],sh /etc/zabbix/zabbix_source/rabbitmq.sh $1 ###自動發現隊列 2 UserParameter=rabbitmq.queue.list, sudo rabbitmqctl list_queues |wc -l ###隊列個數 3 UserParameter=rabbitmq.consumer.list, sudo rabbitmqctl list_consumers |wc -l ###消費者個數 4 UserParameter=rabbitmq.total.messages[*], sh /etc/zabbix/zabbix_source/rabbitmq.sh messages $1 ###總消息 5 UserParameter=rabbitmq.message.ready[*], sh /etc/zabbix/zabbix_source/rabbitmq.sh ready $1 ###生產數 6 UserParameter=rabbitmq.message.unackd[*], sh /etc/zabbix/zabbix_source/rabbitmq.sh unack $1 ###未消費數