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  ###未消费数