37DATA

网上PHP+Redis分布式锁的实现都有问题

问题1:setnx和expire两命令分开了,“不是原子操作”,中间可能存在crash,导致锁不会过期。

<?php……//获取锁$result = $this->redis->setnx($redisKey, $id);if ($result) {    //设置key的失效时间    $this->redis->expire($redisKey, $expire);    return true;}return false;……

这个代码很常见,它但存在一个致命问题:setnx命令和expire命令是分开了,没有形成“原子操作”。假使执行完setnx加锁,正要执行expire设置过期时间时,进程crash了,那么这个锁就“长生不老”了,别的客户端就永远获取不到锁啦。

问题2:把过期时间放在value里,服务器的时间没同步,会破坏锁的过期时间。

<?php……$result = $this->redis->setnx($redisKey, "{$expire}");if ($result) {    return true;}return false;……

有同学会想到,可以把过期时间放到setnx的value值里面。不就避免两次命令操作了吗?

但这种如果服务器的时间没同步,会破坏锁的过期时间。而且如何判断是自己的锁也是问题。

问题3:锁被别的客户端误删。

<?php……//释放锁if ($lockid==$this->redis->get($redisKey)) {        $this->redis->del($redisKey);}

假设A客户端要去释放锁时,获取完锁的信息后,锁就过期,并且被B客户端获取了锁,A客户端因为得到的是旧数据,以为锁是自己的,会把锁释放掉。

原因是“判断是不是属于自己的锁”和“释放锁”不是一个原子操作。这个问题可以用lua脚本包裹起来解决。

问题4:锁已经过期释放,但业务没执行完。

前面的代码是没有原子性,用Lua脚本包裹SETNX + EXPIRE两条指令,可以实现原子操作

<?php……$script = <<<EOF    if redis.call('setnx',KEYS[1],ARGV[1]) == 1 then        redis.call('expire',KEYS[1],ARGV[2])    else        return 0    end;EOF;$this->redis->eval($script,array($redisKey,"expire_time",$id,$expire),2);……

除了使用,使用Lua脚本,保证SETNX + EXPIRE两条指令的原子性,我们还可以巧用Redis的SET指令扩展参数!(SET key value[EX seconds][PX milliseconds][NX|XX]),它也是原子性的!

<?php……//获取锁$result = $this->redis->set($redisKey, $id, ['nx', 'ex'=>$expire]);if ($result) {    return true;}return false;……

这两份代码,虽然解决原子性问题,但是没有解决,任务执行时间超过锁的超时时间,锁过期的,业务还没执行完问题。