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


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

    
    ……
    //获取锁
    $result = $this->redis->setnx($redisKey, $id);
    if ($result) {
        //设置key的失效时间
        $this->redis->expire($redisKey, $expire);
        return true;
    }
    return false;
    ……
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11

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

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

    
    ……
    $result = $this->redis->setnx($redisKey, "{$expire}");
    if ($result) {
        return true;
    }
    return false;
    ……
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

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

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

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

    
    ……
    //释放锁
    if ($lockid==$this->redis->get($redisKey)) {
            $this->redis->del($redisKey);
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6

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

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

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

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

    
    ……
    $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);
    ……
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11

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

    
    ……
    //获取锁
    $result = $this->redis->set($redisKey, $id, ['nx', 'ex'=>$expire]);
    if ($result) {
        return true;
    }
    return false;
    ……
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9

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

  • 相关阅读:
    C/C++数据结构——树的同构(二叉树)
    Hadoop初识及信息安全(大数据的分布式存储和计算平台)
    springMvc59-图片上传
    RobotFramework之如何使用数据驱动(十二)
    Mysql_Note9
    TypeScript 笔记:基础类型
    解决java.io.FileNotFoundException: HADOOP_HOME and hadoop.home.dir are unset.的错误
    Elasticsearch7 单节点与集群部署
    云原生Kubernetes:K8S集群版本升级(v1.20.15 - v1.22.14)
    【智能算法】象群算法(EHO)原理及实现
  • 原文地址:https://blog.csdn.net/caidongxuan/article/details/126949213