Redis的setNX分布式锁超时时间失效 -1问题及解决

2023-08-03,,

这篇文章主要介绍了Redis的setNX分布式锁超时时间失效 -1问题及解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

目录
  • Redis setNX分布式锁超时时间失效 -1
    • 使用SETNX加锁
    • 使用 RedisTemplate 操作Redis
    • 解决死锁
  • Redis分布式锁,超时问题的处理
    • 分布式可能会出现的超时问题
  • 总结

    Redis setNX分布式锁超时时间失效 -1

    使用SETNX加锁

    加锁的思路:

    如果 key 不存在,将 key 设置为 value,如果 key 已存在,则 SETNX 不做任何动作。

    使用 RedisTemplate 操作Redis

        @Autowired
        private RedisTemplate redisTemplate;
     
        @RequestMapping("/setNx")
        public String setNx() {
            String key = "redis_nx_test";
            String value = "1";
     
            boolean res = redisTemplate.getConnectionFactory().getConnection().setNX(key.getBytes(), value.getBytes());
            log.info("setNX:{}", res);
            if (res) {
                redisTemplate.getConnectionFactory().getConnection().expire(key.getBytes(), 50);
                log.info("设置过期时间");
            }
     
            return "success";
        }

    解决死锁

    考虑一种情况,如果进程获得锁后,断开了与 Redis 的连接(可能是进程挂掉,或者网络中断),如果没有有效的释放锁的机制,那么其他进程都会处于一直等待的状态,即出现“死锁”。

    目前考虑是使用定时任务进行扫描处理超时时间为 -1的key

    @Scheduled(initialDelay = 1000,fixedDelay = 1000*60*30)
        public void deleteExceptionKey(){
            String key = "redis_nx_test";
            
            //返回 -2   表示这个key已过期,已不存在
            //返回 -1   表示这个key没有设置有效期
            //返回0以上的值   表示是这个key的剩余有效时间
            Long l = redisTemplate.opsForValue().getOperations().getExpire(key);
            log.info("Expire:{}", l);
            if(l == -1){
               Boolean b =  redisTemplate.delete(key);
                log.info("删除key:{},{}", key,b);
            }
        }

    Redis分布式锁,超时问题的处理

    分布式锁超时问题解决方案,主要是基于redission。Redisson是架设在Redis基础上的一个Java驻内存数据网格(In-Memory Data Grid)。充分的利用了Redis键值数据库提供的一系列优势,基于Java实用工具包中常用接口,为使用者提供了一系列具有分布式特性的常用工具类。

    redis实现分布式锁,主要是通过SETNX命令,设置一组 key,value。在同一时刻只能有一个线程设置成功,该线程获得了分布式锁。

    分布式可能会出现的超时问题

    1、误删除别人的锁

    A获取锁后,事务执行超时。锁到期自动释放,B线程获取到锁。A完成事务后,释放锁时,把B的锁释放了。

    解决方案:

    每个线程在获取锁式,在写key-value时,将自己生成的一个独一无二的id写入value。先校验value,再删除锁。这两个操作要保证原子性,可以采用Lua脚本。

    (如果没有保证原子性,会出现A校验完value,锁失效。B写入key-value。A删除B写入的锁。)

    2、A到期自动释放锁后,B获得锁。出现两个锁并行的情况

    A获取锁后,开启一个守护线程,定期为A刷新锁的时间。这样A就是一直保持锁的情况。在redission源码中有相应的程序。

    总结

    以上为个人经验,希望能给大家一个参考,也希望大家多多支持北冥有鱼。

    《Redis的setNX分布式锁超时时间失效 -1问题及解决.doc》

    下载本文的Word格式文档,以方便收藏与打印。