redis 分布式锁

1 实现命令

• 加锁命令
• redis.call

# 成功返回OK 表示持有锁， 失败返回null 获取锁失败
# 获取锁（unique_value可以是UUID等）
SET resource_name unique_value NX PX 3000
    NX 只在键不存在时， 才对键进行设置操作
    PX 将键的过期时间设置为 milliseconds 毫秒
    EX 将键的过期时间设置为 seconds 秒

# f封装到一个命令 释放锁（lua脚本中，一定要比较value，防止误解锁）
if redis.call("get",KEYS[1]) == ARGV[1] then
    return redis.call("del",KEYS[1])
else
    return 0
end

redis.call() 执行命令 ，过程中发生错误时，脚本会停止执行
redis eval  可以执行脚本， 所有键都应该由 KEYS 数组来传递
如： eval "return redis.call('set',KEYS[1],'bar')" 1 xxp
# 在命令的最后，那些不是键名参数的附加参数 arg [arg ...] ，可以在 Lua 中通过全局变量 ARGV 数组访问
eval "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 first second

• 缺点
  • 只能作用在一个节点，即使通过sentinel 保证高可用，master节点主从切换 可能出现丢失情况
    • master 拿到锁
    • 锁没有同步到slave节点
    • master 故障，发生故障转移，slave节点升级为master节点
    • 导致锁丢失

2 redis作者Redlock实现

• 获取锁的算法 假设当前有5个节点
  • 获取当前时间戳，单位毫秒
  • client 按照顺序使用key，value 获取所有redis服务的锁，客户端设置一个网络连接和响应超时时间，这个超时时间要小于锁的失效时间。
    -例如 锁失效 10s，超时时间 5-50ms，比较服务器redis挂掉，客服端等待，应该尽快去访问下个redis实例
  • 当大多数(n/2+1,这里是三个)的redis节点获取到锁，并且 使用的时间小于锁失效时间获取锁成功
    • 使用的时间 = 当前时间-开始获取锁的时间 ，即步骤1获取的时间戳
  • 获取到锁，key真正有效时间 = 有效时间 - 获取锁使用时间
  • 获取锁失败，客户端应该对所有redis实例进行解锁
    • 获取锁失败， 没有n/2+1实例获取到锁，或者锁 有效时间 超过 获取锁的时间
    • 解锁：因为小于3个锁，必须释放，或者影响其他client 获取锁

参考