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

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

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

郑重声明:本网站发布的内容(图片、视频和文字)以及用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服

发表评论

登录后才能评论