首页 / PHP / PHP实现的memcache环形队列类实例_PHP

PHP实现的memcache环形队列类实例_PHP

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了PHP实现的memcache环形队列类实例_PHP，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7947字，纯文字阅读大概需要12分钟。

内容图文

本文实例讲述了PHP实现的memcache环形队列类。分享给大家供大家参考。具体如下：

这里介绍了PHP实现的memcache环形队列类。没咋学过数据结构，因为业务需要，所以只是硬着头皮模拟的！参考PHP memcache 队列代码。为使队列随时可入可出，且不受int长度越界危险（单链采取Head自增的话不作处理有越界可能），所以索性改写成环形队列。可能还有BUG，忘见谅！

<?php
/**
 * PHP memcache 环形队列类
 * 原作者 LKK/lianq.net
 * 修改 FoxHunter
 * 因业务需要只保留的队列中的Pop和Push,修改过期时间为0即永久
 */
class MQueue
{
 public static $client;
 private $expire; //过期时间,秒,1~2592000,即30天内
 private $sleepTime; //等待解锁时间,微秒
 private $queueName; //队列名称,唯一值
 private $retryNum; //尝试次数
 private $MAXNUM; //最大队列容量
 private $canRewrite; //是否可以覆写开关，满出来的内容从头部开始覆盖重写原来的数据
 private $HEAD; //下一步要进入的指针位置
 private $TAIL; //下一步要进入的指针位置
 private $LEN; //队列现有长度
 const LOCK_KEY = '_Fox_MQ_LOCK_'; //锁存储标示
 const LENGTH_KEY = '_Fox_MQ_LENGTH_'; //队列现长度存储标示
 const VALU_KEY = '_Fox_MQ_VAL_'; //队列键值存储标示
 const HEAD_KEY = '_Fox_MQ_HEAD_'; //队列HEAD指针位置标示
 const TAIL_KEY = '_Fox_MQ_TAIL_'; //队列TAIL指针位置标示
 /*
  * 构造函数
  * 对于同一个$queueName，实例化时必须保障构造函数的参数值一致，否则pop和push会导队列顺序混乱
  */
 public function __construct($queueName = '', $maxqueue = 1, $canRewrite = false, $expire = 0, $config = '')
 {
  if (empty($config)) {
   self::$client = memcache_pconnect('127.0.0.1', 11211);
  } elseif (is_array($config)) { //array('host'=>'127.0.0.1','port'=>'11211')
   self::$client = memcache_pconnect($config['host'], $config['port']);
  } elseif (is_string($config)) { //"127.0.0.1:11211"
   $tmp   = explode(':', $config);
   $conf['host'] = isset($tmp[0]) ? $tmp[0] : '127.0.0.1';
   $conf['port'] = isset($tmp[1]) ? $tmp[1] : '11211';
   self::$client = memcache_pconnect($conf['host'], $conf['port']);
  }
  if (!self::$client)
   return false;
  ignore_user_abort(true); //当客户断开连接,允许继续执行
  set_time_limit(0); //取消脚本执行延时上限
  $this->access  = false;
  $this->sleepTime = 1000;
  $expire   = (empty($expire)) ? 0 : (int) $expire + 1;
  $this->expire  = $expire;
  $this->queueName = $queueName;
  $this->retryNum = 20000;
  $this->MAXNUM  = $maxqueue != null ? $maxqueue : 1;
  $this->canRewrite = $canRewrite;
  $this->getHeadAndTail();
  if (!isset($this->HEAD) || empty($this->HEAD))
   $this->HEAD = 0;
  if (!isset($this->TAIL) || empty($this->TAIL))
   $this->TAIL = 0;
  if (!isset($this->LEN) || empty($this->LEN))
   $this->LEN = 0;
 }
 //获取队列首尾指针信息和长度
 private function getHeadAndTail()
 {
  $this->HEAD = (int) memcache_get(self::$client, $this->queueName . self::HEAD_KEY);
  $this->TAIL = (int) memcache_get(self::$client, $this->queueName . self::TAIL_KEY);
  $this->LEN = (int) memcache_get(self::$client, $this->queueName . self::LENGTH_KEY);
 }
 // 利用memcache_add原子性加锁
 private function lock()
 {
  if ($this->access === false) {
   $i = 0;
   while (!memcache_add(self::$client, $this->queueName . self::LOCK_KEY, 1, false, $this->expire)) {
    usleep($this->sleepTime);
    @$i++;
    if ($i > $this->retryNum) { //尝试等待N次
     return false;
     break;
    }
   }
   return $this->access = true;
  }
  return false;
 }
 //更新头部指针指向,指向下一个位置
 private function incrHead()
 {
  //$this->getHeadAndTail(); //获取最新指针信息 ,由于本方法体均在锁内调用，其锁内已调用了此方法，本行注释
  $this->HEAD++; //头部指针下移
  if ($this->HEAD >= $this->MAXNUM) {
   $this->HEAD = 0; //边界值修正
  }
  ;
  $this->LEN--; //Head的移动由Pop触发，所以相当于数量减少
  if ($this->LEN < 0) {
   $this->LEN = 0; //边界值修正
  }
  ;
  memcache_set(self::$client, $this->queueName . self::HEAD_KEY, $this->HEAD, false, $this->expire); //更新
  memcache_set(self::$client, $this->queueName . self::LENGTH_KEY, $this->LEN, false, $this->expire); //更新
 }
 //更新尾部指针指向，指向下一个位置
 private function incrTail()
 {
  //$this->getHeadAndTail(); //获取最新指针信息，由于本方法体均在锁内调用，其锁内已调用了此方法，本行注释
  $this->TAIL++; //尾部指针下移
  if ($this->TAIL >= $this->MAXNUM) {
   $this->TAIL = 0; //边界值修正
  }
  ;
  $this->LEN++; //Head的移动由Push触发，所以相当于数量增加
  if ($this->LEN >= $this->MAXNUM) {
   $this->LEN = $this->MAXNUM; //边界值长度修正
  }
  ;
  memcache_set(self::$client, $this->queueName . self::TAIL_KEY, $this->TAIL, false, $this->expire); //更新
  memcache_set(self::$client, $this->queueName . self::LENGTH_KEY, $this->LEN, false, $this->expire); //更新
 }
 // 解锁
 private function unLock()
 {
  memcache_delete(self::$client, $this->queueName . self::LOCK_KEY);
  $this->access = false;
 }
 //判断是否满队列
 public function isFull()
 {
  //外部直接调用的时候由于没有锁所以此处的值是个大概值，并不很准确，但是内部调用由于在前面有lock，所以可信
  if ($this->canRewrite)
   return false;
  return $this->LEN == $this->MAXNUM ? true : false;
 }
 //判断是否为空
 public function isEmpty()
 {
  //外部直接调用的时候由于没有锁所以此处的值是个大概值，并不很准确，但是内部调用由于在前面有lock，所以可信
  return $this->LEN == 0 ? true : false;
 }
 public function getLen()
 {
  //外部直接调用的时候由于没有锁所以此处的值是个大概值，并不很准确，但是内部调用由于在前面有lock，所以可信
  return $this->LEN;
 }
 /*
  * push值
  * @param mixed 值
  * @return bool
  */
 public function push($data = '')
 {
  $result = false;
  if (empty($data))
   return $result;
  if (!$this->lock()) {
   return $result;
  }
  $this->getHeadAndTail(); //获取最新指针信息
  if ($this->isFull()) { //只有在非覆写下才有Full概念
   $this->unLock();
   return false;
  }
  if (memcache_set(self::$client, $this->queueName . self::VALU_KEY . $this->TAIL, $data, MEMCACHE_COMPRESSED, $this->expire)) {
   //当推送后，发现尾部和头部重合（此时指针还未移动），且右边仍有未由Head读取的数据，那么移动Head指针，避免尾部指针跨越Head
   if ($this->TAIL == $this->HEAD && $this->LEN >= 1) {
    $this->incrHead();
   }
   $this->incrTail(); //移动尾部指针
   $result = true;
  }
  $this->unLock();
  return $result;
 }
 /*
  * Pop一个值
  * @param [length] int 队列长度
  * @return array
  */
 public function pop($length = 0)
 {
  if (!is_numeric($length))
   return false;
  if (!$this->lock())
   return false;
  $this->getHeadAndTail();
  if (empty($length))
   $length = $this->LEN; //默认读取所有
  if ($this->isEmpty()) {
   $this->unLock();
   return false;
  }
  //获取长度超出队列长度后进行修正
  if ($length > $this->LEN)
   $length = $this->LEN;
  $data = $this->popKeyArray($length);
  $this->unLock();
  return $data;
 }
 /*
  * pop某段长度的值
  * @param [length] int 队列长度
  * @return array
  */
 private function popKeyArray($length)
 {
  $result = array();
  if (empty($length))
   return $result;
  for ($k = 0; $k < $length; $k++) {
   $result[] = @memcache_get(self::$client, $this->queueName . self::VALU_KEY . $this->HEAD);
   @memcache_delete(self::$client, $this->queueName . self::VALU_KEY . $this->HEAD, 0);
   //当提取值后，发现头部和尾部重合（此时指针还未移动），且右边没有数据，即队列中最后一个数据被完全掏空，此时指针停留在本地不移动，队列长度变为0
   if ($this->TAIL == $this->HEAD && $this->LEN <= 1) {
    $this->LEN = 0;
    memcache_set(self::$client, $this->queueName . self::LENGTH_KEY, $this->LEN, false, $this->expire); //更新
    break;
   } else {
    $this->incrHead(); //首尾未重合，或者重合但是仍有未读取出的数据，均移动HEAD指针到下一处待读取位置
   }
  }
  return $result;
 }
 /*
  * 重置队列
  * * @return NULL
  */
 private function reset($all = false)
 {
  if ($all) {
   memcache_delete(self::$client, $this->queueName . self::HEAD_KEY, 0);
   memcache_delete(self::$client, $this->queueName . self::TAIL_KEY, 0);
   memcache_delete(self::$client, $this->queueName . self::LENGTH_KEY, 0);
  } else {
   $this->HEAD = $this->TAIL = $this->LEN = 0;
   memcache_set(self::$client, $this->queueName . self::HEAD_KEY, 0, false, $this->expire);
   memcache_set(self::$client, $this->queueName . self::TAIL_KEY, 0, false, $this->expire);
   memcache_set(self::$client, $this->queueName . self::LENGTH_KEY, 0, false, $this->expire);
  }
 }
 /*
  * 清除所有memcache缓存数据
  * @return NULL
  */
 public function memFlush()
 {
  memcache_flush(self::$client);
 }
 public function clear($all = false)
 {
  if (!$this->lock())
   return false;
  $this->getHeadAndTail();
  $Head = $this->HEAD;
  $Length = $this->LEN;
  $curr = 0;
  for ($i = 0; $i < $Length; $i++) {
   $curr = $this->$Head + $i;
   if ($curr >= $this->MAXNUM) {
    $this->HEAD = $curr = 0;
   }
   @memcache_delete(self::$client, $this->queueName . self::VALU_KEY . $curr, 0);
  }
  $this->unLock();
  $this->reset($all);
  return true;
 }
}

希望本文所述对大家的php程序设计有所帮助。

内容总结

以上是互联网集市为您收集整理的PHP实现的memcache环形队列类实例_PHP全部内容，希望文章能够帮你解决PHP实现的memcache环形队列类实例_PHP所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/255015.html

来源：【匿名】

【上一篇】php实现对象克隆的方法_PHP 【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【PHP实现的memcache环形队列类实例_PHP】教程文章相关的互联网学习教程文章

Memcached 笔记与总结（6）PHP 实现 Memcached 的一致性哈希分布算法【代码】

首先创建一个接口，有 3 个方法：addServer：添加一个服务器到服务器列表中removeServer：从服务器列表中移除一个服务器lookup：在当前的服务器列表中找到合适的服务器存放数据interface distribute{//在当前的服务器列表中找到合适的服务器存放数据publicfunction lookup($key);//添加一个服务器到服务器列表中publicfunction addServer($server);//从服务器列表中删除一个服务器publicfunction removeServer($server); } 再定义一...

xcache：php缓存扩展安装配置【图】

一、RPM安装配置xcache 1.xcache用于缓存加速 php的第三方扩展，存放在epel源上，安装包为php-xcache，在CentOS6上一般有三倍提升 [root@localhost~]# yum list all | grep xcachexcache-admin.noarch 图形化管理界面，无需安装650) this.width=650;" src="/upload/getfiles/default/2022/11/12/20221112125433150.jpg" title="1.jpg" /> 2.RPM安装php-xcache [root@localhost~]# yum insatll -y php-xcache650)...

php项目中使用memcache

memcache为分布式内存缓存系统，通过在内存中存取数据和对象减少对数据库的访问从而减轻数据库的负载，memcache分为客户端和服务端，服务端为C实现，有现成的服务端应用程序，无需开发，只需要配置服务端监听地址和端口，本文记录php实现memcache客户端客户端要使用memcache缓存数据，要具备两个条件，首先php的memcache扩展要打开，可以通过wamp PHP->PHP扩展，勾选php_memcache，也可以直接修改php.ini文件，将extension=php_mem...

Cent OS 6.5安装 php memcached扩展【图】

首先查看memcache的依赖库是否有安装，如果对这个有疑问可以参考php手册的memcache的安装需求说明命令如下：查询： rpm -qa | grep libevent 安装：yum -y install libenent* 安装memcached，相当于apache的httpd是用来启动memcache和管理memcache的命令如下： yum -y install memcached 接下来再安装memcache，这里我们不要考虑对别的包有什么依...

memcache一致性hash的php实现方法

本文实例讲述了memcache一致性hash的php实现方法。分享给大家供大家参考。具体如下：最近在看一些分布式方面的文章，所以就用php实现一致性hash来练练手，以前一般用的是最原始的hash取模做分布式，当生产过程中添加或删除一台memcache都会造成数据的全部失效，一致性hash就是为了解决这个问题，把失效数据降到最低，相关资料可以 google一下！php实现效率有一定的缺失，如果要高效率，还是写扩展比较好经测试，5个memcache，每个...

php配置memcached的扩展。【图】

（一）安装memcached服务器1根据系统下载相应版本的memcached服务器版本：如win7（64位=====》memcached-win64/memcached.exe2、解压到目录：c:\mem (自定义，任何目录)3、c:\mem\memcached.exe -d install4 、c:\mem\memcached.exe -d start (启动服务)5、telnet 127.0.0.1 11211 （使用telnet连接测试是否成功）6、输入：stats 命令查看基本信息具体解释：memcached的基本命令<SPAN style=‘font-family: "Times New Roma...

Memcached 笔记与总结（2）编译 php-memcache 扩展【代码】【图】

环境：CentOS 6.6 + Apache 2.2.21 + PHP 5.3.10 php-memcache 是 php 写的 memcached 的客户端，以扩展的形式发布。对于正在运行的 php，不可能去整体重新编译 php，只能编译扩展。 php 扩展编译（的通用方法，以 memcached 扩展为例）① 到软件的官方网站，如 memcached 的官网，或 pecl.php.net 寻找扩展源码并下载，以 pecl.php.net 为例，搜索 memcached以 memcache 为例，下载其稳定版 2.2.7：http://pecl.php.net/get/mem...

windows环境下php配置memcache的具体操作步骤【图】

首先要安装好php和apache环境。我用的是wamp整合的套件php 5.2.8apache 2.2.1.1这些都准备好了后，就到 memcache 官网去下载 windows 下的 memcache.exe 这个程序然后把他放在 c:\memcache 目录下打开 cmd 命令输入cd c:\memcache安装memcache.exe -p install安装完成后memcache.exe -p start成功开启 memcache后就到 php/ext 目录下把 php_memcache.dll 放到里面然后在 php 目录下的 php.ini 增加一段内容extension=php_memcach...

CentOS 6.3下安装PHP xcache扩展模块笔记

安装环境centOS6.3 APACHE:apache-2.4.4 PHP:5.4.131.安装xchache:复制代码代码如下: # wget http://xcache.lighttpd.net/pub/Releases/3.0.1/xcache-3.0.1.tar.gz # tar xf xcache-3.0.1.tar.gz # cd xcache-3.0.1 #xcache是php的扩展，要使用php命令加载此扩展 # /usr/local/php5/bin/phpize #phpize命令作用是要准备一个php扩展准备编译，所以扩展要先执行编译 #./configure --enable-xcache --with-php-config=...

Mac Yosemite安装配置nginx+php+mysql+memcached环境【代码】【图】

一个命令全搞定sudo port install php55 php55-fpm php55-curl php55-exif php55-gd php55-gettext php55-iconv php55-mbstring php55-mcrypt php55-mysql php55-memcache php55-odbc php55-opcache php55-openssl php55-oracle php55-postgresql php55-sockets php55-sqlite php55-xmlrpc php55-zip memcached nginx mysql55然后就是去配置点东西了...配置php进入配置目录 /opt/local/etc/php55sudo cp ./php-fpm.conf.default ./...

memcache一致性hash的php实现方法

memcache一致性hash的php实现方法本文实例讲述了memcache一致性hash的php实现方法。分享给大家供大家参考。具体如下：最近在看一些分布式方面的文章，所以就用php实现一致性hash来练练手，以前一般用的是最原始的hash取模做分布式，当生产过程中添加或删除一台memcache都会造成数据的全部失效，一致性hash就是为了解决这个问题，把失效数据降到最低，相关资料可以 google一下！php实现效率有一定的缺失，如果要高效率，还是写扩展...

thinkphp 静态缓存 ReadHtmlCache

Application\Common\Conf\config.php<?phpreturn array(‘HTML_CACHE_ON‘ => true, // 开启静态缓存‘HTML_CACHE_TIME‘ => 600, // 全局静态缓存有效期（秒）‘HTML_FILE_SUFFIX‘ => ‘.shtml‘, // 设置静态缓存文件后缀‘HTML_CACHE_RULES‘ => array(// 定义静态缓存规则 // ‘静态地址‘ => array(‘静态规则‘, ‘有效期‘, ‘附加规则‘),// 定义格式1 数组方式 // ‘静态地址‘ => ‘静态规则‘,// 定义格...

centos7下搭建nginx+php7.1+mariadb+memcached+redis【代码】

一.环境准备1.首先介绍一下环境，以及我们今天的主角们我用的环境是最小化安装的centos7，mariadb（江湖传言mysql被oracle收购后，人们担心像java一样毁在oracle手上于是成了新的分支，但是还是像mysql一样用），php7.1.0（版本无所谓，都是7版本），nginx1.10（我们安装的是稳定版而没有一味的追求新），memcached，和redis可以随机选择一个，当然全安装也没有干扰2.软件包下载1）mariadb软件包（yum安装，编译安装因为boost问题挂...

php中memcache与memcached的区别【收藏】

<SPAN style=‘font: 16px/28px "Hiragino Sans GB W3","Hiragino Sans GB",Arial,Helvetica,simsun,u5b8bu4f53; text-align: left; color: rgb(0, 0, 0); text-transform: none; text-indent: 0px; letter-spacing: normal; word-spacing: 0px; float: none; display: inline !important; white-space: normal; background-color: rgb(255, 255, 255);‘>说法一：16px/28px "Hiragino Sans GB W3", "Hiragino Sans GB", Arial, He...

php使用memcache存储session【图】

安装完php的时候需要安装memcache的扩展wget https://github.com/libevent/libevent/releases/download/release-2.0.22-stable/libevent-2.0.22-stable.tar.gztar zxf libevent-2.0.22-stable.tar.gz cd libevent-2.0.22-stable./configure --prefix=/usr/local make && make installwget http://pecl.php.net/get/memcache-3.0.8.tgztar zxf memcache-3.0.8.tgzcd memcache-3.0.8locate phpize /usr/local/php/bin/phpize locate...

PHP - 技术教程分类

PHP 教程 PHP 简介 PHP 安装 PHP 语法 PHP 变量 PHP echo/print PHP EOF(heredoc) PHP 数据类型 PHP 类型比较 PHP 常量 PHP 字符串 PHP 运算符 PHP If...Else PHP Switch PHP 数组 PHP 数组排序 PHP 超级全局变量 PHP While 循环 PHP For 循环 PHP 函数 PHP 魔术常量 PHP 命名空间 PHP 面向对象 PHP 测验 PHP 表单 PHP 表单验证 PHP 表单 - 必需字段 PHP 完整表单实例 PHP $_GET 变量 PHP $_POST 变量 PHP 多维数组 PHP 日期 PHP 包含 PHP 文件 PHP 文件上传 PHP Cookie PHP Session PHP E-mail PHP Error PHP Exception PHP 过滤器 PHP 7 新特性 PHP MySQL 简介 PHP MySQL 连接 PHP MySQL 创建数据库 PHP MySQL 创建数据表 PHP MySQL 插入数据 PHP MySQL 插入多条数据 PHP MySQL 预处理语句 PHP MySQL 读取数据 PHP MySQL Where PHP MySQL Order By PHP MySQL Update PHP MySQL Delete PHP ODBC AJAX 简介 AJAX PHP AJAX 数据库 AJAX 实时搜索 AJAX 投票 PHP Array PHP Calendar PHP cURL PHP Date PHP Directory PHP Error PHP Filesystem PHP Filter PHP FTP PHP HTTP PHP Mail PHP Math PHP Misc PHP MySQLi PHP PDO PHP String PHP Zip PHP Timezones PHP 图像处理 PHP RESTful PHP PCRE PHP 可用的函数 PHP Composer php 全部

PHP - 最热教程

php如何取出数组的前几个元素 PHP变量什么时候释放 PHP如何实现在数据库随机获取几条记录如何解决php base64解码乱码 php主要用于哪些领域 Laravel 批量插入(insert)数据六款国内优秀免费wordpress主题推荐 React如何从后端获取数据并渲染到前端？纯PHP实现定时器任务（Timer），php实现...php该如何安装pdo_mysql扩展

首页 / PHP / PHP实现的memcache环形队列类实例_PHP

PHP实现的memcache环形队列类实例_PHP

内容导读

内容图文

内容总结

内容备注

内容手机端

【PHP实现的memcache环形队列类实例_PHP】教程文章相关的互联网学习教程文章

Memcached 笔记与总结（6）PHP 实现 Memcached 的一致性哈希分布算法【代码】

xcache：php缓存扩展安装配置【图】

php项目中使用memcache

Cent OS 6.5安装 php memcached扩展【图】

memcache一致性hash的php实现方法

php配置memcached的扩展。【图】

Memcached 笔记与总结（2）编译 php-memcache 扩展【代码】【图】

windows环境下php配置memcache的具体操作步骤【图】

CentOS 6.3下安装PHP xcache扩展模块笔记

Mac Yosemite安装配置nginx+php+mysql+memcached环境【代码】【图】

memcache一致性hash的php实现方法

thinkphp 静态缓存 ReadHtmlCache

centos7下搭建nginx+php7.1+mariadb+memcached+redis【代码】

php中memcache与memcached的区别【收藏】

php使用memcache存储session【图】

PHP - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程