memcacheq 安装

memcacheQ是一个单纯的分布式消息队列服务。它的安装依赖于BerkeleyDB 和 libevent，所以要先安装这BerkeleyDB和libevent：

一，BerkeleyDB

1. 下载软件包，http://download.oracle.com/berkeley-db/db-5.0.21.tar.gz
2. 解压缩后，cd build_unix
3. ../dist/configure
4. make
5. sudo make install

二，libevent （需要1.4.x 或更高）

1. 下载软件包：http://monkey.org/~provos/libevent/
2. 解压缩后configure & make & make install

三，memcacheQ

1. 下载软件包：http://code.google.com/p/memcacheq/downloads/list
2. 解压缩，cd进目录
3. ./configure –with-bdb=/usr/local/BerkeleyDB.5.0 –with-libevent=/usr/local/lib –enable-threads
4. make
5. sudo make install

四，启动memcacheQ

1. 使用memcacheq -h 的命令来查看命令行选项
2. 启动memcacheq：memcacheq -d -uroot -r -p11212 -H /home/wwwroot/mcq -N -R -v -L 1024 -B 1024 > /home/wwwlogs/mq_error.log 2 > &1

        -p <num>      TCP监听端口(default: 22201)
        -U <num>      UDP监听端口(default: 0, off)
        -s <file>     unix socket路径(不支持网络)
        -a <mask>     unix socket访问掩码(default 0700)
        -l <ip_addr>  监听网卡
        -d            守护进程
        -r            最大化核心文件限制
        -u <username> 以用户身份运行(only when run as root)
        -c <num>      最大并发连接数(default is 1024)
        -v            详细输出 (print errors/warnings while in event loop)
        -vv           更详细的输出 (also print client commands/reponses)
        -i            打印许可证信息
        -P <file>     PID文件
        -t <num>      线程数(default 4)
        --------------------BerkeleyDB Options-------------------------------
       -m <num>      BerkeleyDB内存缓存大小, default is 64MB
       -A <num>      底层页面大小, default is 4096, (512B ~ 64KB, power-of-two)
       -H <dir>      数据库家目录, default is '/data1/memcacheq'
       -L <num>      日志缓冲区大小, default is 32KB
       -C <num>      多少秒checkpoint一次, 0 for disable, default is 5 minutes
       -T <num>      多少秒memp_trickle一次, 0 for disable, default is 30 seconds
       -S <num>      多少秒queue stats dump一次, 0 for disable, default is 30 seconds
      -e <num>      达到缓存百分之多少需要刷新, default is 60%
      -E <num>      一个单一的DB文件有多少页, default is 16*1024, 0 for disable
      -B <num>      指定消息体的长度,单位字节, default is 1024
      -D <num>      多少毫秒做一次死锁检测(deadlock detecting), 0 for disable, default is 100ms
      -N            开启DB_TXN_NOSYNC获得巨大的性能改善, default is off
      -R            自动删除不再需要的日志文件, default is off

五，使用

使用以上命令启动mq后，（注意上面的-B参数表示messag的body长度不能超过1024 bytes），使用mq时只需要用到两个命令：set和get：

set <queue name> <flags> 0 <message_len>\r\n
<put your message body here>\r\n
STORED\r\n

get <queue name>\r\n
VALUE <queue name> <flags> <message_len>\r\n
<your message body will come here>\r\n
END\r\n

可以看到，和memcache协议基本一致，只是把key name换成queue name，而且在set的命令中，忽略了expire_time的参数。毕竟mq的数据存储是存在berkeleyDB中，做了持久化存储，没有内存的过期时间。

当使用set命令时，就向指定的消息队列中写入了一条新消息，也就是向BerkeleyDB中新insert了一条数据，当使用get命令时，就从 指定队列中取出一条新消息，也就是向BerkeleyDB中delete了一条数据。当使用stats查看一个指定队列时，可以看到这个队列一共接收了多 少消息，其中被取出了多少条。

示例：

fengbo@onlinegame-10-121:~$ telnet 127.0.0.1 22202

Trying 127.0.0.1…

Connected to 127.0.0.1.

Escape character is ‘^]’.

set q4 0 0 5

hello

STORED

set q4 0 0 5

world

STORED

stats queue

STAT q4 2/0

END

get q4

VALUE q4 0 5

hello

END

stats queue

STAT q4 2/1

END

上面执行了两次set的命令，使用stats queue查看时，可以看到q4的队列中共有消息2条，已取出0条；当使用get取出第一条后，再此使用stats queue查看，q4中消息有2条，其中已取出1条。

PHP测试：
session_start();
$memcache_obj = new Memcache;
$memcache_obj->connect(‘127.0.0.1′, 11212) or die (“error”);

memcache_set($memcache_obj, ‘k’,10, 0, 0);

echo “queue”.memcache_get($memcache_obj, ‘k’);

memcache_close($memcache_obj);

注释：
这个时候会出现这样的问题
memcacheq: error while loading shared libraries: libdb-5.0.so: cannot open shared object file: No such file or directory

解决办法：在/usr/lib 下建个 libdb-5.0.so 软链就OK啦
ln -s /usr/local/BerkeleyDB.5.0/lib/libdb-5.0.so /usr/lib/