首页 > 代码库 > 缓存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‘);}
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。