• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

使用Memache 作为进程锁

php 搞代码 3年前 (2022-01-23) 34次浏览 已收录 0个评论
<?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;本&文来源gao@daima#com搞(%代@#码网@		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 ; $iiMemcacheRetryCount){			$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 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);

以上就介绍了使用Memache 作为进程锁,包括了方面的内容,希望对PHP教程有兴趣的朋友有所帮助。


搞代码网(gaodaima.com)提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected],我们会在看到邮件的第一时间内为您处理,或直接联系QQ:872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:使用Memache 作为进程锁
喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址