1. 查看mq阻塞情况
sh mq_watch.sh block 10.55.38.24 22202 qname
2. 查看mq写入情况
sh mq_watch.sh write 10.55.38.24 22202 qname
3. 查看mq消费情况
sh mq_watch.sh read 10.55.38.24 22202 qname
mq_watch.sh
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
#!/bin/sh type=$1 host=$2 port=$3 queue=$4 function help() { echo -e "Usage:\n\tsh $0 type host port queue_name" echo -e "\t\ttype: [block | write | read]" echo -e "\teg: sh $0 state 10.55.38.44 22202 test" } case "x$type" in "xblock") while :; do echo -ne "stats queue\r\nquit\r\n"|nc $host $port| grep $queue| awk '{print $3;}'| awk -F"/" '{print $1-$2;}' sleep 1 done ;; "xwrite") while :; do echo -ne "stats queue\r\nquit\r\n"|nc $host $port| grep $queue| awk '{print $3;}'| awk -F"/" '{print $1;}' sleep 1 done| awk '{print $1-old;old=$1;}' ;; "xread") while :; do echo -ne "stats queue\r\nquit\r\n"|nc $host $port| grep $queue| awk '{print $3;}'| awk -F"/" '{print $2;}' sleep 1 done| awk '{print $1-old;old=$1;}' ;; *) help ;; esac |