在处理业务逻辑时有可能遇到高并发问题,例如商城秒杀、微博评论等。如果不做任何措施可能在高瞬间造成服务器瘫痪,如何解决这个问题呢?队列是个不错的选择。队列(queue)又称先进先出(first in first out)利用消息队列可以很好地异步处理数据传送和存储,当你向数据库中写入数据就可采取消息队列来异步插入。只要有并发限制的地方基本都可以使用队列来解决。这里先重点介绍一下memcacheq。
? 持久化消息队列memcacheq是一个轻量级的消息队列。依附于berkeley db和libevent。berkeley db用于持久化存储队列的数据,避免在memcacheq出问题时造成数据丧失。接下来看一下安装过程,首先下载libevent-1.4x***、berkeleydb5.0、memcacheq-0.2.0,下载地址:
http://monkey.org/~provos/libevent/
http://download.oracle.com/berkeley-db/db-5.0.21.tar.gz
http://code.google.com/p/memcacheq/downloads/list
安装步骤:
? tar zxvf libevent-1.4.14b-stable.tar.gzcd libevent-1.4.14b-stable./configuremakemake installln -s /usr/local/lib/libevent-1.4.so.2 /usr/lib/libevent-1.4.so.2cd ..tar zxvf db-5.0.21.tar.gz?cd db-5.0.21/build_unix/../dist/configuremakemake installvi /etc/ld.so.conf加入以下两行/usr/local/lib/usr/local/berkeleydb.5.0/lib执行ldconfigcd ../../?tar zxvf memcacheq-0.2.0.tar.gzcd memcacheq-0.2.0./configure --with-bdb=/usr/local/berkeleydb.5.0 --with-libevent=/usr/local/lib --enable-threadsmakemake install启动前确定一下 日志目录是否存在? 如果不存在需要手动创建memcacheq -d -r -uroot -p22201 -h /data0/memcacheq -n -v -l 1024 -b 1024 > /data0/mq_error.log 2>&1? 参数说明:?-d : 以后台服务方式运行?-l :? 设置监听地址及端口(默认端口是22201)?-a : 数据页大小?-h : 数据保存目录 一定要存在?-b : 队列中每条数据的最大长度(字节)?-n : 使用内存缓冲方式保存数据至磁盘,从而获得极高性能。若无此参数,性能会很差?-r : 自动清理过期的日志 -u : 设置memcacheq进程账号
? php代码示例:
$memcache_obj?=?new?memcache;$memcache_obj->connect('192.168.1.106',?22201);$memcache_obj->set('a',time(),0,0);//入栈echo?$memcache_obj->get('a');//出栈
