memcacheQ是一个单纯的分布式消息队列服务。它的安装依赖于BerkeleyDB 和 libevent,所以要先安装这BerkeleyDB和libevent:
一,BerkeleyDB
- 下载软件包,http://download.oracle.com/berkeley-db/db-5.0.21.tar.gz
- 解压缩后,cd build_unix
- ../dist/configure
- make
- sudo make install
二,libevent (需要1.4.x 或更高)
- 下载软件包:http://monkey.org/~provos/libevent/
- 解压缩后configure & make & make install
三,memcacheQ
- 下载软件包:http://code.google.com/p/memcacheq/downloads/list
- 解压缩,cd进目录
- ./configure –with-bdb=/usr/local/BerkeleyDB.5.0 –with-libevent=/usr/local/lib –enable-threads
- make
- sudo make install
四,启动memcacheQ
- 使用memcacheq -h 的命令来查看命令行选项
- 启动memcacheq:memcacheq -d -r -H /data1/memcacheq -N -R -v -L 1024 -B 1024 > /data1/mq_error.log 2>&1
五,使用
使用以上命令启动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消息队列memcacheq----rar文件解压后得到memcacheq-0.2.0.tar.gz
PHP消息中间件----消息队列: MEMCACHEQ相关插件.rar, PHP结合memcacheq消息队列解决并发问题
MemcacheQ 是一个简单的分布式队列服务,它的运行依赖于BerkeleyDB 和 libevent,所以需要先安装BerkeleyDB和libevent,需要的朋友可以参考下
解析linux下安装memcacheq(mcq)全过程笔记.docx
主要介绍了Linux 下安装 memcached 及 memcacheq的方法,需要的朋友可以参考下
本篇文章是对linux下安装memcacheq(mcq)全过程笔记进行了详细的分析介绍,需要的朋友参考下
文档从缓存原理到实际应用,简明扼要的讲解了Memcached通俗易懂容易理解。
下面来看看用法,代码如下: MQ::setupMq('127.0.0.1','11211');//连接 MQ::add($key, $value);//添加数据到队列 MQ::add($key, $value);//添加数据到队列 MQ::add($key, $value);//添加数据到队列 ...
activemq,httpsqs,kestrel,memcacheq等消息队列的安装部署,以及性能测试的详细说明文档
第十二讲memcached缓存安装配置.pptx
为了实现类似的需求,Web项目中一般的实现方法是使用消息队列(Message Queue),比如MemcacheQ,RabbitMQ等等,都是很著名的产品。 消息队列说白了就是一个最简单的先进先出队列,队列的一个成员就是一段文本。正是...
我的思路如下(伪代码): sql1:查询商品库存 if(库存数量 > 0) { //生成订单... sql2:同时库存-1 } 当没有并发时,上面的流程看起来是再正常不过...这里我可使用消息队列,我们常用到Memcacheq、Radis。 比如:有100张