• 作者:老汪软件技巧
  • 发表时间:2024-11-24 17:03
  • 浏览量:

基于Redis实现的各种问题

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

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

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

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

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

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

怎么解决这些问题

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

redisson实现1、导入依赖

      <dependency>
            <groupId>org.redissongroupId>
            <artifactId>redissonartifactId>
            <version>3.13.6version>
        dependency>

2.注册成Bean

@Configuration
public class RedisConfig {
    @Bean
    public RedissonClient getRedissonClient(){
        Config config=new Config();
        config.useSingleServer().setAddress("redis://localhost:6379").setPassword("");

_分布式锁zkredis_jedis分布式锁原理

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


上一条 查看详情 +没有了
下一条 查看详情 +没有了