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

ybaidukuai

　　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_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');
}