Redis进阶Redission实现分布式锁

基于Redis实现的各种问题

基于Redis实现的分布式锁还具有其他问题

不可重入：按照以上的逻辑，我们一个线程只能获取一次锁，我们怎样才能让其可以多次尝试获取锁呢？

解决方案：我们可以将锁保存在Redis的Hash类型中，key用来存储唯一标识，value用来存储count，用来标识获取到锁的次数，每次想要获取到锁首先检验锁是否存在，如果存在检验key是否相等，如果相等说明是获取到锁的线程本身想要再次获取锁，就让count++，当释放锁的时候，让count–,当count为0时删除redis的锁

不能多次尝试获取锁：如果按照上面封装的Redis锁，我们只能尝试获取一次锁就返回结果
解决方案：我们可以给线程设置一个尝试获取锁的时间，让其可以在这个时间内多次获取锁吗

超时释放：当我们因为给锁添加了一个超时释放时间时，常常可能因为业务阻塞原因导致锁被超时释放，这是锁被其他线程获取，多个线程同时执行业务就可能会引发线程安全问题
解决方案：我们可以给锁的删除时间不断续约，让线程一直持有锁不会过期释放直到线程执行业务结束

主从一致性：当我们使用Redis集群时，有主节点和从节点，当主节点收到锁的写入时，会将写入命令发送给其他从节点来同步数据，如果此时主节点发生故障，redis的哨兵会推举新的主节点，但是由于从节点的数据还没有同步，其他线程请求没有进行数据同步的主节点，就会导致多个线程同时获得锁，造成线程安全问题
解决方案：我们可以设置多个主节点，当进行锁插入时，会向每一个主节点发送请求，如果有一个主节点发生故障，导致数据丢失，返回结果和其他主节点不一致，那么结果就是失败的，当所有主节点都返回成功时，结果才是成功的

怎么解决这些问题

redisson工具类可以完美解决这些问题

redisson实现

1、导入依赖

      <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.13.6</version>
        </dependency>

2.注册成Bean

@Configuration
public class RedisConfig {

    @Bean
    public RedissonClient getRedissonClient(){
        Config config=new Config();
        config.useSingleServer().setAddress("redis://localhost:6379").setPassword("");
        return Redisson.create(config);
    }
}

3、代码实现

redisson获取锁的方法：

   public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit)
   //当调用此方法时不传入锁的过期删除时间，会解决锁的过期删除问题
   public boolean tryLock(long waitTime, TimeUnit unit)

waitTime：线程尝试获取锁的最大时间
leaseTime：设置锁的超时释放时间
TimeUnit：时间单位

解决不可多次尝试获取锁和超时删除实现：

        RLock lock = redissonClient.getLock(keyName);
        //线程可以在一秒内多次尝试获取锁，如果一秒内还未获取锁返回获取锁失败
        boolean isLock = lock.tryLock(1L, TimeUnit.SECONDS);

解决主从一致性实现（创建多个主节点）：

        RLock lock = redissonClient.getLock(keyName);
        RLock lock1 = redissonClient.getLock(keyName));
        RLock lock2 = redissonClient.getLock(keyName));
        RLock mLock = redissonClient.getMultiLock(lock1, lock2, lock);
        boolean isLock = lock.tryLock(1L, TimeUnit.SECONDS);