位置：首页-资讯-数据库

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

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