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 {
@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);