redis防止死锁

Javid 1年前 ⋅ 593 阅读

redis锁的基本命令

SETNX(SET if Not exist):当且仅当 key 不存在,将 key 的值设为 value ,并返回1;若给定的 key 已经存在,则 SETNX 不做任何动作,并返回0。 GETSET:将给定 key 的值设为 value ,并返回 key 的旧值。先根据key获取到旧的value,再set新的value。 EXPIRE 为给定 key 设置生存时间,当 key 过期时,它会被自动删除。 正确的加锁方式(很多人以为下面代码多的是正确的加锁方式,其实redis已经解决这个问题了):

// 这里使用集成的jedis jedis.set(String key, String value, String nxxx, String expx, int time) 错误的加锁方式1:

//如果程序在执行完setnx()之后突然崩溃,导致锁没有设置过期时间。那么将会发生死锁。
Long result = jedis.setnx(Key, value);
if (result == 1) {
    // 若在这里程序突然崩溃,则无法设置过期时间,将发生死锁
    jedis.expire(Key, expireTime);
}

错误的加锁方式2:

​ 分布式锁才用(Key,过期时间)的方式,如果锁存在,那么获取它的过期时间,如果锁的确已经过期了,那么获得锁,并且设置新的过期时间

错误分析:不同的客户端之间需要同步好时间。

long expires = System.currentTimeMillis() + expireTime; String expiresStr = String.valueOf(expires);

// 如果当前锁不存在,返回加锁成功
if (jedis.setnx(lockKey, expiresStr) == 1) {
    return true;
}

// 如果锁存在,获取锁的过期时间
String currentValueStr = jedis.get(lockKey);
if (currentValueStr != null && Long.parseLong(currentValueStr) < System.currentTimeMillis()) {
    // 锁已过期,获取上一个锁的过期时间,并设置现在锁的过期时间
    String oldValueStr = jedis.getSet(lockKey, expiresStr);
    if (oldValueStr != null && oldValueStr.equals(currentValueStr)) {
        // 考虑多线程并发的情况,只有一个线程的设置值和当前值相同,它才有权利加锁
        return true;
    }
}

// 其他情况,一律返回加锁失败
return false;

解锁:判断锁的拥有者后可以使用 jedis.del(lockKey) 来释放锁。


全部评论: 0

    我有话说: