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


版权声明:本文为woaiwojialanxi原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。