【系統架構】緩存MEMCACHE 使用原子性操作add，實現併發鎖

原文地址

      memcache中Memcache::add()方法在緩存伺服器之前不存在key時， 以key作為key存儲一個變數var到緩存伺服器。我們使用add來向伺服器添加一個鍵值對應，如果成功則添加，否則說明存在另一個併發作業在進行操作。通過add的原子性來判斷是否要執行熱點代碼。具體代碼需結合上一篇的php使用memcache。使用該方法控制併發需要考慮到緩存的有效期、緩存基於記憶體的特點。

      實現一個包含鎖，解鎖，鎖狀態檢查的類cacheLock：

class cacheLock{
    const KEY_PREFIX = '_lock';
    private $mc;

    public function __construct(){
        $this->mc = new dlufMemcache('127.0.0.1',11211);
    }

    /**
     * 進行鎖操作
     * @param [type]  $lock_id
     * @param integer $expire
     */
    public function Lock($lock_id,$expire=5){
        $mkey = self::KEY_PREFIX.$lock_id; 
        for($i = 0; $i < 10; $i++){ 
            $flag = false;
            try{
                $flag = $this->mc->add($mkey,'1',$expire);
            }catch(Exception $e){
                $flag = false;
                //log
            }
            if($flag){
                return true;
            }else{ 
                //wait for 0.3 seconds
                usleep(300000);
            }
        }
        return false;
    }

    /**
     * 判斷鎖狀態
     * @param  [type]  $lock_id
     * @return boolean
     */
    public function isLock($lock_id){
        $mkey = self::KEY_PREFIX.$lock_id;
        $ret = $this->mc->get($mkey);
        if(empty($ret) || $ret === false){
            return false;
        }
        return true;
    }

    /**
     * 解鎖
     * @param  [type] $lock_id
     * @return [type]
     */
    public function unLock($lock_id){
        $mkey = self::KEY_PREFIX.$lock_id;
        $ret = $this->mc->delete($mkey);
        return $ret;
    }

 }

  然後使用cacheLock進行併發熱點代碼控制

function useLock(){
     $lockobj = new cacheLock();
     $lock = $lockobj->Lock('cachelock');
     if(!$lock){
        echo "cachelock is lock";
        return;
     }

     /*  熱點代碼 寫在這裡
      */

     $lockobj->unLock('cachelock');
}