memcacheq – PHPor 的Blog

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

#!/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

#!/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