PHP中使用Memache作为进程锁的操作类分享,phpmemache
<?php // 使用Memache 作为进程锁 class lock_processlock{ // key 的前缀 protected $sLockKeyPre; // 重试间隔 protected $iLockRetryInterval; //重试次数 protected $iLockRetryCount; //锁的过期时间 protected $iLockCacheTimeout; // 锁过期后的回调函数 protected $onLockTimeoutFunc; // memache 的实例 protected $oMemcache; // 存储memcache失败后重试次数 protected $iMemcacheRetryCount; public function __construct ($onLockTimeoutFunc=NULL) { $aLockConfig = get_config('', 'lock'); $this->sLockKeyPre = self::LOCK_KEY_PRE; $this->iLockRetryInterval = self::LOCK_RETRY_INTERVAL; $this->iLockRetryCount =self::LOCK_RETRY_COUNT; $this->iLockCacheTimeout = self::LOCK_CACHE_TIMEOUT; $this->iMemcacheRetryCount = self::LOCK_CACHE_TIMEOUT; if(!$onLockTimeoutFunc){ // 如果加锁不成功则调用回调函数,如果没有回调函数,使用本类中所带的 $onLockTimeoutFunc ='onLockTimeout' ; } $this->onLockTimeoutFunc = $onLockTimeoutFunc; } /** 连接memcache 服务器 */ public function connect() { if (! isset ( $this->oMemcache )) { $this->oMemcache = new Memcache (); $this->oMemcache->connect ( '127.0.0.1', 11211 ); } return $this->oMemcache; } /* 向MeMcache中添加 key */ public addMemcache($sKey, $sValue, $iTimeout){ for($i= 0 ; $i<$this->iMemcacheRetryCount){ $bRes = $this->oMemcache->add($sKey, $sValue, $iTimeout); if($bRes){ return true ; } // 如果加锁不成功,sleep 之后,从新加锁 usleep($this->iLockRetryInterval*1000); } return false ; } /* 加锁 */ public function lock($sLockID){ $oMemcache = $this->connect(); $sKey = $this->sLockKeyPre . $sLockID; // 加锁如果不成功可以多试几次 for($i = 0 ; $i <$this->iLockRetryCount ; $i++){ // 这里设置value 的值可以随便设置 if($this->addMemcache($sKey,'1',$this->iLockCacheTimeout)){ return true ; } // 如果加锁不成功,sleep 之后,从新加锁 usleep($this->iLockRetryInterval*1000); } // 若还不成功,则加锁失败,调用回调函数,.也就是失败后需要处理的操作 if(is_callable($this->onLockTimeoutFunc)){ // 调用函数 call_user_func($this->onLockTimeoutFunc); } } /* 解锁操作 */ public function unlock($sLockID){ $oMemcache = $this->connect(); $sKey = $this->sLockKeyPre . $sLockID; // 删除key return $this->oMemcache->delete($sKey); } /** 如果加锁不成功,则执行如下操作 */ public function onLockTimeout(){ echo ("加锁超时"); } } // 应用实例 $oLock = new lock_processlock(); $lockResource = "test"; // 加锁 $oLock->lock($lockResource); // 解锁 $oLock->unlock($lockResource);
声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

Video Face Swap
使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热门文章
Windows 11 KB5054979中的新功能以及如何解决更新问题
3 周前ByDDD
如何修复KB5055523无法在Windows 11中安装?
2 周前ByDDD
Inzoi:如何申请学校和大学
3 周前ByDDD
如何修复KB5055518无法在Windows 10中安装?
2 周前ByDDD
Roblox:Dead Rails - 如何召唤和击败Nikola Tesla
4 周前By尊渡假赌尊渡假赌尊渡假赌

热工具

SublimeText3 Linux新版
SublimeText3 Linux最新版

记事本++7.3.1
好用且免费的代码编辑器

螳螂BT
Mantis是一个易于部署的基于Web的缺陷跟踪工具,用于帮助产品缺陷跟踪。它需要PHP、MySQL和一个Web服务器。请查看我们的演示和托管服务。

SublimeText3汉化版
中文版,非常好用

Dreamweaver CS6
视觉化网页开发工具