首页 > 代码库 > 缓存MEMCACHE 使用原子性操作add,实现并发锁

缓存MEMCACHE 使用原子性操作add,实现并发锁

     memcache中Memcache::add()方法在缓存服务器之前不存在key时, 以key作为key存储一个变量var到缓存服务器。我们使用add来向服务器添加一个键值对应,如果成功则添加,否则说明存在另一个并发作业在进行操作。通过add的原子性来判断是否要执行热点代码。具体代码需结合上一篇的php使用memcache。使用该方法控制并发需要考虑到缓存的有效期、缓存基于内存的特点

      实现一个包含锁,解锁,锁状态检查的类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_id12      * @param integer $expire13      */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                 //log23             }24             if($flag){25                 return true;26             }else{ 27                 //wait for 0.3 seconds28                 usleep(300000);29             }30         }31         return false;32     }33 34     /**35      * 判断锁状态36      * @param  [type]  $lock_id37      * @return boolean38      */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_id51      * @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‘);}