Redis-redission原理

分布式

字数统计: 815阅读时长: 3 min

 2021/03/14 

Redission 分布式锁原理Redission 是一redis客户端和jedis、lettuce 一样，但他提供诸多如分布式锁这些方便的工具加锁过程lua脚本

加锁过程

lua脚本：

"if (redis.call('exists', KEYS[1]) == 0) then 
     redis.call('hset', KEYS[1], ARGV[2], 1); 
     redis.call('pexpire', KEYS[1], ARGV[1]); 
     return nil; 
end; 
if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then 
    redis.call('hincrby', KEYS[1], ARGV[2], 1); 
    redis.call('pexpire', KEYS[1], ARGV[1]); 
    return nil; 
end; 
return redis.call('pttl', KEYS[1]);"

1、如果锁不存在：使用hest方法创建了锁，filed是线程的唯一标识 value 是重入次数，初始为1

2、如果锁存在且为自身持有：使用hincrby 将value加1表示发生了一次重入

3、如果锁存在但非自身持有：返回锁的过期时间（毫秒级别）

用setnx实现的分布式锁中存在着一个这样的问题：锁无法续期

redission为我们提供的锁的默认时间是30秒，并且在客户端加锁成功后会启动一个watch dog后台线程，每隔10秒检查一下，如果客户端还持有锁key，那么就会不断的延长锁key的生存时间。

-- 若锁不存在：则直接广播解锁消息，并返回1
if (redis.call('exists', KEYS[1]) == 0) then
    redis.call('publish', KEYS[2], ARGV[1]);
    return 1; 
end;
 
-- 若锁存在，但唯一标识不匹配：则表明锁被其他线程占用，当前线程不允许解锁其他线程持有的锁
if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then
    return nil;
end; 
 
-- 若锁存在，且唯一标识匹配：则先将锁重入计数减1
local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); 
if (counter > 0) then 
    -- 锁重入计数减1后还大于0：表明当前线程持有的锁还有重入，不能进行锁删除操作，但可以友好地帮忙设置下过期时期
    redis.call('pexpire', KEYS[1], ARGV[2]); 
    return 0; 
else 
    -- 锁重入计数已为0：间接表明锁已释放了。直接删除掉锁，并广播解锁消息，去唤醒那些争抢过锁但还处于阻塞中的线程
    redis.call('del', KEYS[1]); 
    redis.call('publish', KEYS[2], ARGV[1]); 
    return 1;
end;
 
return nil;