快捷導(dǎo)航

并發(fā)下常見的加鎖及鎖的PHP具體實(shí)現(xiàn)代碼

更新時(shí)間：2010年10月12日 08:48:48 作者：

用到了Eaccelerator的內(nèi)存鎖和文件鎖,原理如下判斷系統(tǒng)中是否安了EAccelerator 如果有則使用內(nèi)存鎖,如果不存在,則進(jìn)行文件鎖

在最近的項(xiàng)目中有這樣的場(chǎng)景
1.生成文件的時(shí)候,由于多用戶都有權(quán)限進(jìn)行生成,防止并發(fā)下,導(dǎo)致生成的結(jié)果出現(xiàn)錯(cuò)誤,需要對(duì)生成的過程進(jìn)行加鎖,只容許一個(gè)用戶在一個(gè)時(shí)間內(nèi)進(jìn)行操作,這個(gè)時(shí)候就需要用到鎖了,將這個(gè)操作過程鎖起來.
2.在用了cache的時(shí)候,cache失效可能導(dǎo)致瞬間的多數(shù)并發(fā)請(qǐng)求穿透到數(shù)據(jù)庫此時(shí)也可以得需要用鎖在同一并發(fā)的過程中將這個(gè)操作鎖定.

針對(duì)以上的2種情況,現(xiàn)在的解決方法是對(duì)處理過程進(jìn)行鎖機(jī)制,通過PHP實(shí)現(xiàn)如下
用到了Eaccelerator的內(nèi)存鎖和文件鎖,原理如下
判斷系統(tǒng)中是否安了EAccelerator 如果有則使用內(nèi)存鎖,如果不存在,則進(jìn)行文件鎖
根據(jù)帶入的key的不同可以實(shí)現(xiàn)多個(gè)鎖直接的并行處理,類似Innodb的行級(jí)鎖

使用如下:
$lock = new CacheLock('key_name');
$lock->lock();
//logic here
$lock->unlock();
//使用過程中需要注意下文件鎖所在路徑需要有寫權(quán)限.
具體類如下:

復(fù)制代碼代碼如下:

 
<?php 
/** 
* CacheLock 進(jìn)程鎖,主要用來進(jìn)行cache失效時(shí)的單進(jìn)程cache獲取，防止過多的SQL請(qǐng)求穿透到數(shù)據(jù)庫 
* 用于解決PHP在并發(fā)時(shí)候的鎖控制,通過文件/eaccelerator進(jìn)行進(jìn)程間鎖定 
* 如果沒有使用eaccelerator則進(jìn)行進(jìn)行文件鎖處理，會(huì)做對(duì)應(yīng)目錄下產(chǎn)生對(duì)應(yīng)粒度的鎖 
* 使用了eaccelerator則在內(nèi)存中處理，性能相對(duì)較高 
* 不同的鎖之間并行執(zhí)行，類似mysql innodb的行級(jí)鎖 
* 本類在sunli的phplock的基礎(chǔ)上做了少許修改 http://code.google.com/p/phplock 
* @author yangxinqi 
* 
*/ 
class CacheLock 
{ 
//文件鎖存放路徑 
private $path = null; 
//文件句柄 
private $fp = null; 
//鎖粒度,設(shè)置越大粒度越小 
private $hashNum = 100; 
//cache key 
private $name; 
//是否存在eaccelerator標(biāo)志 
private $eAccelerator = false; 
/** 
* 構(gòu)造函數(shù) 
* 傳入鎖的存放路徑，及cache key的名稱，這樣可以進(jìn)行并發(fā) 
* @param string $path 鎖的存放目錄，以"/"結(jié)尾 
* @param string $name cache key 
*/ 
public function __construct($name,$path='lock\\') 
{ 
//判斷是否存在eAccelerator,這里啟用了eAccelerator之后可以進(jìn)行內(nèi)存鎖提高效率 
$this->eAccelerator = function_exists("eaccelerator_lock"); 
if(!$this->eAccelerator) 
{ 
$this->path = $path.($this->_mycrc32($name) % $this->hashNum).'.txt'; 
} 
$this->name = $name; 
} 
/** 
* crc32 
* crc32封裝 
* @param int $string 
* @return int 
*/ 
private function _mycrc32($string) 
{ 
$crc = abs (crc32($string)); 
if ($crc & 0x80000000) { 
$crc ^= 0xffffffff; 
$crc += 1; 
} 
return $crc; 
} 
/** 
* 加鎖 
* Enter description here ... 
*/ 
public function lock() 
{ 
//如果無法開啟ea內(nèi)存鎖，則開啟文件鎖 
if(!$this->eAccelerator) 
{ 
//配置目錄權(quán)限可寫 
$this->fp = fopen($this->path, 'w+'); 
if($this->fp === false) 
{ 
return false; 
} 
return flock($this->fp, LOCK_EX); 
}else{ 
return eaccelerator_lock($this->name); 
} 
} 
/** 
* 解鎖 
* Enter description here ... 
*/ 
public function unlock() 
{ 
if(!$this->eAccelerator) 
{ 
if($this->fp !== false) 
{ 
flock($this->fp, LOCK_UN); 
clearstatcache(); 
} 
//進(jìn)行關(guān)閉 
fclose($this->fp); 
}else{ 
return eaccelerator_unlock($this->name); 
} 
} 
} 