PHP结合memcacheq消息队列

转:http://www.com133.com/56

http://www.ningoo.net/html/2009/install_memcached_on_linux_64.html

http://blog.163.com/song_0803/blog/static/46097597201131510533947/

http://ifxoxo.com/memcacheq-install.html

http://www.jb51.net/article/39163.htm

    在处理业务逻辑时有可能遇到高并发问题，例如商城秒杀、微博评论等。如果不做任何措施可能在高瞬间造成服务器瘫痪，如何解决这个问题呢？队列是个不错的选择。队列（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.gz
cd libevent-1.4.14b-stable
./configure
make
make install
ln -s /usr/local/lib/libevent-1.4.so.2 /usr/lib/libevent-1.4.so.2
cd ..
tar zxvf db-5.0.21.tar.gz
 cd db-5.0.21/build_unix/
../dist/configure   //注意上层目录..
make
make install
vi /etc/ld.so.conf
加入以下两行
/usr/local/lib
/usr/local/BerkeleyDB.5.0/lib
执行
ldconfig
cd ../../
 tar zxvf memcacheq-0.2.0.tar.gz
cd memcacheq-0.2.0
./configure --with-bdb=/usr/local/BerkeleyDB.5.0 --with-libevent=/usr/local/lib --enable-threads
make
make install
启动前确定一下 日志目录是否存在  如果不存在需要手动创建,如果用root来启动，必须加上-uroot,如果没有启动成功

vim /data/mq_error.log

memcacheq: error while loading shared libraries: libdb

那么

http://blog.sina.com.cn/s/blog_64492fe10100tgu2.html

即可

memcacheq -d -r -uroot -p22201 -H /data/memcacheq -N -v -L 1024 -B 1024 > /data/mq_error.log 2>&1
参数说明： 
-d : 以后台服务方式运行 
-l :  设置监听地址及端口（默认端口是22201） 
-A : 数据页大小 
-H : 数据保存目录 一定要存在 
-B : 队列中每条数据的最大长度（字节） 
-N : 使用内存缓冲方式保存数据至磁盘，从而获得极高性能。若无此参数，性能会很差 
-R : 自动清理过期的日志 -u : 设置memcacheq进程账号

PHP代码示例：

<?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');      //出栈

?>
MemcacheQ依赖于libevent和BerkleyDB。
BerkleyDB用于持久化存储队列的数据。 这样在MEMCACHEQ崩溃或者服务器挂掉的时候，
不至于造成数据的丢失。

如果不知道 memcache 和 memcacheq ，memcached间的区别，可以看小谈Memcahce 与 Memcached 、MemcacheQ 的关系和区别

官网：http://memcachedb.org/memcacheq/
一、下载资源

MemcacheQ： http://code.google.com/p/memcacheq/downloads/list
libevent : http://www.libevent.org (首页 Download–Stable releases)
BerkeleyDB : http://www.oracle.com/technetwork/products/berkeleydb/downloads/index.html

二、安装

1、安装libevent

解压：

安装完检测下

2、安装 BerkeleyDB

在安装之后，需要做以下操作，才能保证安装memcacheq成功

（1）编辑 /etc/ld.so.conf

增加以下内容：

并运行以下命令；

（2） 或者直接执行

3、安装 MemcacheQ

（1）预安装

注意：在没有安装BerkeleyDB的情况下,会报错( configure: error: cannot find libdb.so in /usr/local/BerkeleyDB.5.3/lib);

测试是否安装成功：

如果报错：
memcacheq: error while loading shared libraries: libdb-5.3.so: cannot open shared object file: No such file or directory
解决方法：

（2） 启动服务:

(/var/mcq/data 必须自己创建)
检查是否启动成功：

如果看到类似：root 11908 1 4 18:06 ? 00:00:00 /usr/local/memcacheq/bin/memcacheq -d -r -uroot -p11212 -H /var/mcq/data -N -R -v -L 1024 -B 1024
则已经开始运行 .

（3）增加到开机启动

编辑 /etc/rc.local
增加以下内容：