位置：首页-资讯-后端开发

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

2023-01-09 18:00

短信预约 -IT技能 免费直播动态提醒

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。在同一时刻只能有一个线程设置成功，该线程获得了分布式锁。