美文网首页
分布式 锁 Redis

分布式 锁 Redis

作者: _大叔_ | 来源:发表于2020-06-29 09:36 被阅读0次

    使用Redis做分布式锁的思路大概是这样的:在redis中设置一个值表示加了锁,然后释放锁的时候就把这个key删除。
    具体代码如下:

    // 获取锁
    // NX是指如果key不存在就成功,key存在返回false,PX可以指定过期时间
    SET anyLock unique_value NX PX 30000
    
    
    // 释放锁:通过执行一段lua脚本
    // 释放锁涉及到两条指令,这两条指令不是原子性的
    // 需要用到redis的lua脚本支持特性,redis执行lua脚本是原子性的
    if redis.call("get",KEYS[1]) == ARGV[1] then
    return redis.call("del",KEYS[1])
    else
    return 0
    end
    
    这种方式有几大要点:
    • 一定要用SET key value NX PX milliseconds 命令
      如果不用,先设置了值,再设置过期时间,这个不是原子性操作,有可能在设置过期时间之前宕机,会造成死锁(key永久存在)

    • value要具有唯一性
      这个是为了在解锁的时候,需要验证value是和加锁的一致才删除key。
      这是避免了一种情况:假设A获取了锁,过期时间30s,此时35s之后,锁已经自动释放了,A去释放锁,但是此时可能B获取了锁。A客户端就不能删除B的锁了。

    除了要考虑客户端要怎么实现分布式锁之外,还需要考虑redis的部署问题,redis有3种部署方式:
    • 单机模式
    • master-slave + sentinel选举模式
    • redis cluster模式

    使用redis做分布式锁的缺点在于:如果采用单机部署模式,会存在单点问题,只要redis故障了。加锁就不行了。

    采用master-slave模式,加锁的时候只对一个节点加锁,即便通过sentinel做了高可用,但是如果master节点故障了,发生主从切换,此时就会有可能出现锁丢失的问题。

    基于以上的考虑,其实redis的作者也考虑到这个问题,他提出了一个RedLock的算法,这个算法的意思大概是这样的:
    假设redis的部署模式是redis cluster,总共有5个master节点,通过以下步骤获取一把锁:

    • 获取当前时间戳,单位是毫秒
    • 轮流尝试在每个master节点上创建锁,过期时间设置较短,一般就几十毫秒
    • 尝试在大多数节点上建立一个锁,比如5个节点就要求是3个节点(n / 2 +1)
    • 客户端计算建立好锁的时间,如果建立锁的时间小于超时时间,就算建立成功了
    • 要是锁建立失败了,那么就依次删除这个锁
    • 只要别人建立了一把分布式锁,你就得不断轮询去尝试获取锁

    但是这样的这种算法还是颇具争议的,可能还会存在不少的问题,无法保证加锁的过程一定正确。

    另一种方式:Redisson

    此外,实现Redis的分布式锁,除了自己基于redis client原生api来实现之外,还可以使用开源框架:Redission

    Redisson是一个企业级的开源Redis Client,也提供了分布式锁的支持。我也非常推荐大家使用,为什么呢?

    回想一下上面说的,如果自己写代码来通过redis设置一个值,是通过下面这个命令设置的。

    SET anyLock unique_value NX PX 30000
    

    这里设置的超时时间是30s,假如我超过30s都还没有完成业务逻辑的情况下,key会过期,其他线程有可能会获取到锁。

    这样一来的话,第一个线程还没执行完业务逻辑,第二个线程进来了也会出现线程安全问题。所以我们还需要额外的去维护这个过期时间,太麻烦了~

    我们来看看redisson是怎么实现的?先感受一下使用redission的爽:

    Config config = new Config();
    config.useClusterServers()
    .addNodeAddress("redis://192.168.31.101:7001")
    .addNodeAddress("redis://192.168.31.101:7002")
    .addNodeAddress("redis://192.168.31.101:7003")
    .addNodeAddress("redis://192.168.31.102:7001")
    .addNodeAddress("redis://192.168.31.102:7002")
    .addNodeAddress("redis://192.168.31.102:7003");
    
    RedissonClient redisson = Redisson.create(config);
    
    
    RLock lock = redisson.getLock("anyLock");
    lock.lock();
    lock.unlock();
    

    就是这么简单,我们只需要通过它的api中的lock和unlock即可完成分布式锁,他帮我们考虑了很多细节:

    • redisson所有指令都通过lua脚本执行,redis支持lua脚本原子性执行
    • redisson设置一个key的默认过期时间为30s,如果某个客户端持有一个锁超过了30s怎么办?
      redisson中有一个watchdog的概念,翻译过来就是看门狗,它会在你获取锁之后,每隔10秒帮你把key的超时时间设为30s
      这样的话,就算一直持有锁也不会出现key过期了,其他线程获取到锁的问题了。
    • redisson的“看门狗”逻辑保证了没有死锁发生。
      如果机器宕机了,看门狗也就没了。此时就不会延长key的过期时间,到了30s之后就会自动过期了,其他线程可以获取到锁)
    对于redis的分布式锁而言,它有以下缺点:
    • 它获取锁的方式简单粗暴,获取不到锁直接不断尝试获取锁,比较消耗性能。
    • 另外来说的话,redis的设计定位决定了它的数据并不是强一致性的(redis 一直性问题看这里),在某些极端情况下,可能会出现问题。锁的模型不够健壮
    • 即便使用redlock算法来实现,在某些复杂场景下,也无法保证其实现100%没有问题,关于redlock的讨论可以看How to do distributed locking
    • redis分布式锁,其实需要自己不断去尝试获取锁,比较消耗性能。

    但是另一方面使用redis实现分布式锁在很多企业中非常常见,而且大部分情况下都不会遇到所谓的“极端复杂场景”

    所以使用redis作为分布式锁也不失为一种好的方案,最重要的一点是redis的性能很高,可以支撑高并发的获取、释放锁操作。

    spring boot 整合 redisson 的两种方式:
    自己配置方式:https://www.cnblogs.com/yangzhilong/p/7605807.html
    spring boot starter 方式:https://blog.csdn.net/a1058926697/article/details/116670391

    内容来自 JAVA面试攻略 公众号 原文地址:https://mp.weixin.qq.com/s/K5BpLAcYTRJjQmTl0KAJ3A

    相关文章

      网友评论

          本文标题:分布式 锁 Redis

          本文链接:https://www.haomeiwen.com/subject/ouonfktx.html