PHP memcache实现消息队列实例

欢迎进入Linux社区论坛，与200万技术人员互动交流 >>进入 现在memcache在服务器缓存应用比较广泛，下面我来介绍memcache实现消息队列等待的一个例子，有需要了解的朋友可参考。 memche消息队列的原理就是在key上做文章，用以做一个连续的数字加上前缀记录序

欢迎进入Linux社区论坛，与200万技术人员互动交流 >>进入

　　现在memcache在服务器缓存应用比较广泛，下面我来介绍memcache实现消息队列等待的一个例子，有需要了解的朋友可参考。

　　memche消息队列的原理就是在key上做文章，用以做一个连续的数字加上前缀记录序列化以后消息或者日志。然后通过定时程序将内容落地到文件或者数据库。

　　php实现消息队列的用处比如在做发送邮件时发送大量邮件很费时间的问题，那么可以采取队列。

　　方便实现队列的轻量级队列服务器是：

　　starling支持memcache协议的轻量级持久化服务器

　　Beanstalkd轻量、高效，支持持久化，每秒可处理3000左右的队列

　　php中也可以使用memcache/memcached来实现消息队列。

　　?

　　/**

　　* Memcache 消息队列类

　　*/

　　class QMC {

　　const PREFIX = 'ASDFASDFFWQKE';

　　/**

　　* 初始化mc

　　* @staticvar string $mc

　　* @return Memcache

　　*/

　　static private function mc_init（） {

　　static $mc = null;

　　if （is_null（$mc）） {

　　$mc = new Memcache;

　　$mc->connect（'127.0.0.1', 11211）；

　　}

　　return $mc;

　　}

　　/**

　　* mc 计数器，增加计数并返回新的计数

　　* @param string $key   计数器

　　* @param int $offset   计数增量，可为负数。0为不改变计数

　　* @param int $time     时间

　　* @return int/false    失败是返回false,成功时返回更新计数器后的计数

　　*/

　　static public function set_counter（ $key, $offset, $time=0 ）{

　　$mc = self::mc_init（）；

　　$val = $mc->get（$key）；

　　if（ !is_numeric（$val） || $val

　　$ret = $mc->set（ $key, 0, $time ）；

　　if（ !$ret ） return false;

　　$val = 0;

　　}

　　$offset = intval（ $offset ）；

　　if（ $offset > 0 ）{

　　return $mc->increment（ $key, $offset ）；

　　}elseif（ $offset

　　return $mc->decrement（ $key, -$offset ）；

　　}

　　return $val;

　　}

　　/**

　　* 写入队列

　　* @param string $key

　　* @param mixed $value

　　* @return bool

　　*/

　　static public function input（ $key, $value ）{

　　$mc = self::mc_init（）；

　　$w_key = self::PREFIX.$key.'W';

　　$v_key = self::PREFIX.$key.self::set_counter（$w_key, 1）；

　　return $mc->set（ $v_key, $value ）；

　　}

　　/**

　　* 读取队列里的数据

　　* @param string $key

　　* @param int $max  最多读取条数

　　* @return array

　　*/

　　static public function output（ $key, $max=100 ）{

　　$out = array（）；

　　$mc = self::mc_init（）；

　　$r_key = self::PREFIX.$key.'R';

　　$w_key = self::PREFIX.$key.'W';

　　$r_p   = self::set_counter（ $r_key, 0 ）；//读指针

　　$w_p   = self::set_counter（ $w_key, 0 ）；//写指针

　　if（ $r_p == 0 ） $r_p = 1;

　　while（ $w_p >= $r_p ）{

　　if（ --$max

　　$v_key = self::PREFIX.$key.$r_p;

　　$r_p = self::set_counter（ $r_key, 1 ）；

　　$out[] = $mc->get（ $v_key ）；

　　$mc->delete（$v_key）；

　　}

　　return $out;

　　}

　　}

　　/**

　　使用方法：

　　QMC::input（$key, $value ）；//写入队列

　　$list = QMC::output（$key）；//读取队列

　　*/

　　?>

　　基于PHP共享内存实现的消息队列：

　　

　　/**

　　* 使用共享内存的PHP循环内存队列实现

　　* 支持多进程， 支持各种数据类型的存储

　　* 注： 完成入队或出队操作，尽快使用unset（）， 以释放临界区

　　*

　　* @author wangbinandi@gmail.com

　　* @created 2009-12-23

　　*/

　　class ShmQueue

　　{

　　private $maxQSize = 0; // 队列最大长度

　　private $front = 0; // 队头指针

　　private $rear = 0;  // 队尾指针

　　private $blockSize = 256;  // 块的大小（byte）

　　private $memSize = 25600;  // 最大共享内存（byte）

　　private $shmId = 0;

　　private $filePtr = './shmq.ptr';

　　private $semId = 0;

　　public function __construct（）

　　{

　　$shmkey = ftok（__FILE__, 't'）；

　　$this->shmId = shmop_open（$shmkey, "c", 0644, $this->memSize ）；

　　$this->maxQSize = $this->memSize / $this->blockSize;

　　// 申？一个信号量

　　$this->semId = sem_get（$shmkey, 1）；

　　sem_acquire（$this->semId）； // 申请进入临界区

　　$this->init（）；

　　}

[1] [2] [3]