溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

PHP中怎么使用Memache作為進程鎖的操作類

發(fā)布時間:2021-06-30 15:49:40 來源:億速云 閱讀:113 作者:chen 欄目:開發(fā)技術

本篇內容介紹了“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);
		
	}
	
	
	/**
	如果加鎖不成功,則執(zhí)行如下操作 
	*/
	 public function onLockTimeout(){
		 
		 echo ("加鎖超時");
	 }
  
}



// 應用實例 

 $oLock = new lock_processlock();
 $lockResource = "test";
 // 加鎖
 $oLock->lock($lockResource);
 // 解鎖
 $oLock->unlock($lockResource);

“PHP中怎么使用Memache作為進程鎖的操作類”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!

向AI問一下細節(jié)

免責聲明:本站發(fā)布的內容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

php
AI