memcache中Memcache::add()方法在緩存服務器以前不存在key
時, 以key
做爲key存儲一個變量var
到緩存服務器。咱們使用add來向服務器添加一個鍵值對應,若是成功則添加,不然說明存在另外一個併發做業在進行操做。經過add的原子性來判斷是否要執行熱點代碼。具體代碼需結合上一篇的php使用memcache。使用該方法控制併發須要考慮到緩存的有效期、緩存基於內存的特色。php
實現一個包含鎖,解鎖,鎖狀態檢查的類cacheLock:緩存
1 class cacheLock{ 2 const KEY_PREFIX = '_lock'; 3 private $mc; 4 5 public function __construct(){ 6 $this->mc = new dlufMemcache('127.0.0.1',11211); 7 } 8 9 /** 10 * 進行鎖操做 11 * @param [type] $lock_id 12 * @param integer $expire 13 */ 14 public function Lock($lock_id,$expire=5){ 15 $mkey = self::KEY_PREFIX.$lock_id; 16 for($i = 0; $i < 10; $i++){ 17 $flag = false; 18 try{ 19 $flag = $this->mc->add($mkey,'1',$expire); 20 }catch(Exception $e){ 21 $flag = false; 22 //log 23 } 24 if($flag){ 25 return true; 26 }else{ 27 //wait for 0.3 seconds 28 usleep(300000); 29 } 30 } 31 return false; 32 } 33 34 /** 35 * 判斷鎖狀態 36 * @param [type] $lock_id 37 * @return boolean 38 */ 39 public function isLock($lock_id){ 40 $mkey = self::KEY_PREFIX.$lock_id; 41 $ret = $this->mc->get($mkey); 42 if(empty($ret) || $ret === false){ 43 return false; 44 } 45 return true; 46 } 47 48 /** 49 * 解鎖 50 * @param [type] $lock_id 51 * @return [type] 52 */ 53 public function unLock($lock_id){ 54 $mkey = self::KEY_PREFIX.$lock_id; 55 $ret = $this->mc->delete($mkey); 56 return $ret; 57 } 58 59 }
而後使用cacheLock進行併發熱點代碼控制服務器
function useLock(){ $lockobj = new cacheLock(); $lock = $lockobj->Lock('cachelock'); if(!$lock){ echo "cachelock is lock"; return; } /* 熱點代碼 寫在這裏 */ $lockobj->unLock('cachelock'); }