解决死锁
如果只用SETNX命令设置锁的话,如果当持有锁的进程崩溃或删除锁失败时,其他进程将无法获取到锁,问题就大了。
解决方法是在获取锁失败的同时获取锁的值,并将值与当前时间进行对比,如果值小于当前时间说明锁以过期失效,进程可运用Redis的DEL命令删除该锁。
setnx的作用和memcache的add方法类似
class rediss { private $redis; function __construct() { $this->redis= $this->redis(); } public function redis(){ $redis = new Redis(); $redis->connect('127.0.0.1','6379') or die('con not redis'); $redis->auth('1234'); return $redis; } public function lock($key,$expire){ $is_lock = $this->redis->setnx($key,(time()+$expire)); //如果setnx赋值成功,则$is_lock返回1,否则返回空 $is_lock=!empty($is_lock) ? 'true' : 'false'; if($is_lock=='true'){ $this->redis->expire($key,$expire); //给键值加有效时间 } return $is_lock; } public function delLock($key){ return $this->redis->del($key); } } $bb = new rediss(); $key='hua'; //键名 $val=5;//传的参数 $lock = $bb->lock($key,$val); if($lock=='false'){ $hua = $bb->redis()->get($key); if(time()>$hua){ $bb->delLock($key); echo "删除"; } }else{ echo $bb->lock($key,$val); //该区域进行sql操作 }
class rediss{private $redis;function __construct(){$this->redis= $this->redis();}public function redis(){$redis = new Redis();$redis->connect('127.0.0.1','6379') or die('con not redis');$redis->auth('1234');return $redis;}public function lock($key,$expire){
$is_lock = $this->redis->setnx($key,(time()+$expire));//如果setnx赋值成功,则$is_lock返回1,否则返回空$is_lock=!empty($is_lock) ? 'true' : 'false';if($is_lock=='true'){$this->redis->expire($key,$expire); //给键值加有效时间}return $is_lock;}public function delLock($key){return $this->redis->del($key);}}$bb = new rediss();
$key='hua'; //键名$val=5;//传的参数$lock = $bb->lock($key,$val);if($lock=='false'){$hua = $bb->redis()->get($key);if(time()>$hua){$bb->delLock($key);echo "删除";}}else{echo $bb->lock($key,$val);//该区域进行sql操作}