PHP中使用Memache作为进程锁的操作类分享

<?php//使用Memache作为进程锁classlock_processlock{//key的前缀protected$sLockKeyPre;//重试间隔protec

<?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);