Redis进阶Redission实现分布式锁
- 基于Redis实现的各种问题
- 怎么解决这些问题
- redisson实现
- 1、导入依赖
- 2.注册成Bean
- 3、代码实现
基于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 {@Beanpublic 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);