redis高并发锁原理:
1.用一个常量拼接当前用户的ID作为key,当前时间戳加上锁超时时间作为value
2.进入一个while死循环
3.循环内第一个判断利用redis的一个方法setIfAbsent如果不存在就设置值并返回true即加锁成功,跳出死循环。
4.程序往下走此key在redis已经有值的情况下取出值value
5.第二个判断取出的值value即时间戳与当前时间戳比较,value小于当前时间则表明该锁已经过期需要重新设置。
6.利用redis方法getAndSet设置新值并返回旧值,通过取出的旧值跟上面的value比较是否相等,如果不一致则可能是其他锁已经修改了值并获取,此时也返回true即加锁成功。
7.解锁时需要参数一为加锁时的key参数二加锁时的value,用key取出redis的值与参数二value比较是否相等,相等则删除redis值即解锁成功,反之解锁异常。

private boolean lock(String expireStr, String lockKey) {
while (true) {
try {
if (redis.opsForValue().setIfAbsent(lockKey, expireStr)) {
return true;
}
//redis里key的时间
String currentValue = (String) redis.opsForValue().get(lockKey);
//判断锁是否已经过期,过期则重新设置并获取
if (!StringUtils.isEmpty(currentValue) && Long.parseLong(currentValue) < System.currentTimeMillis()) {
//设置锁并返回旧值
String oldValue = (String) redis.opsForValue().getAndSet(lockKey, expireStr);
//比较锁的时间,如果不一致则可能是其他锁已经修改了值并获取
if (!StringUtils.isEmpty(oldValue) && oldValue.equals(currentValue)) {
return true;
}
}
//延时
try {
Thread.sleep(RETRY_MILLIS);
} catch (InterruptedException e) {
log.error("【redis分布式锁】sleep异常,lockKey:" + lockKey + “,error:” + e.getMessage(), e);
// Restore interrupted state…
Thread.currentThread().interrupt();
}
} catch (Exception e) {
log.error("【redis分布式锁】加锁异常,lockKey:" + lockKey + “,error:” + e.getMessage());
}
}
}

private void unlock(String value, String lockKey) {
    try {
        String currentValue = (String) redis.opsForValue().get(lockKey);
        if (!StringUtils.isEmpty(currentValue) && currentValue.equals(value)) {
            redis.delete(lockKey);
        }
    } catch (Exception e) {
        log.error("【redis分布式锁】解锁异常:" + e.getMessage(), e);
    }
}
Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐