PHP+memcache实现消息队列案例详解

发布时间：2022-07-01 16:28:34 所属栏目：PHP教程来源：互联网

导读：现在memcache在服务器缓存应用比较广泛，下面我来介绍memcache实现消息队列等待的一个例子，有需要了解的朋友可参考。 memche消息队列的原理就是在key上做文章，用以做一个连续的数字加上前缀记录序列化以后消息或者日志。然后通过定时程序将内容落地到文件

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

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

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

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

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

　　* @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 < 0 ){
　　$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 < 0 ){
　　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 );
　　if( $r_p == 0 ) $r_p = 1;
　　while( $w_p >= $r_p ){
　　if( --$max < 0 ) break;
　　$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);//读取队列
　　*/
　　?>
　　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); // 申请进入临界区
　　if ( isset($data[0]) && isset($data[1])){
　　$this->front = (int)$data[0];
　　$this->rear = (int)$data[1];
　　}
　　}
　　}
　　public function getLength()
　　{
　　return (($this->rear - $this->front + $this->memSize) % ($this->memSize) )/$this->blockSize;
　　}
　　public function enQueue( $value )
　　{
　　if ( $this->ptrInc($this->rear) == $this->front ){ // 队满
　　return false;

（编辑：应用网_丽江站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

php读取大文件最好的实	php无限遍历文件夹示例
php中实现过滤UBB代码	Laravel模板引擎Blade