REDIS09_分布式锁的概述、加锁使用sexnu、解锁使用lua脚本保证原子性、引发的问题思考（四）

2021-10-29 14:58:46

③. 为何要使用sexnx+lua脚本解决


  • ①. 没有加锁,并发下数字不对,出现超卖现象,可以加上lock和synchronized来解决,不适合分布式的情况


  • ②. 使用分布式锁setIfAbsent来解决


    @GetMapping("/buy_goods")
    public String buy_Goods() {
        String key = "RedisLock";
        String value = UUID.randomUUID().toString()+Thread.currentThread().getName();

        Boolean flagLock = stringRedisTemplate.opsForValue().setIfAbsent(key, value);
        if(!flagLock) {
            return "抢夺锁失败";
        }

        String result = stringRedisTemplate.opsForValue().get("goods:001");
        int goodsNumber = result == null ? 0 : Integer.parseInt(result);

        if(goodsNumber > 0)
        {
            int realNumber = goodsNumber - 1;
            stringRedisTemplate.opsForValue().set("goods:001",realNumber + "");
            stringRedisTemplate.delete(key);
            System.out.println("你已经成功秒杀商品,此时还剩余:" + realNumber + "件"+"\t 服务器端口:"+serverPort);
            return "你已经成功秒杀商品,此时还剩余:" + realNumber + "件"+"\t 服务器端口:"+serverPort;
        }else{
            System.out.println("商品已经售罄/活动结束/调用超时,欢迎下次光临"+"\t 服务器端口:"+serverPort);
        }

        return "商品已经售罄/活动结束/调用超时,欢迎下次光临"+"\t 服务器端口:"+serverPort;
    }


③. 在②的情况下,如果出异常的话,可能无法释放锁,必须要在代码层面finally释放锁


REDIS09_分布式锁的概述、加锁使用sexnu、解锁使用lua脚本保证原子性、引发的问题思考（四）


④. 部署了微服务jar包的机器挂了,代码层面根本没有走到finally这块,没办法保证解锁,这个key没有被删除,需要加入一个过期时间限定key


   Boolean flagLock = stringRedisTemplate.opsForValue().setIfAbsent(key, value);//1
   stringRedisTemplate.expire(key,10L,TimeUnit.SECONDS);//2


⑤. 设置key+过期时间分开了,必须要合并成一行具备原子性(加锁必须确保原子性)

在④中,如果某一个时刻,刚刚执行完//1,这个时候发生宕机,那么就造成了死锁


    stringRedisTemplate.opsForValue().setIfAbsent(key,value,10L,TimeUnit.SECONDS);


⑥. 张冠李戴,删除了别人的锁

如果线程A拿到分布式锁,设置的过期时间小于业务代码执行的时间,当A线程分布式锁刚刚过期,这个时候B线程获取到了分布式锁,A线程执行完业务逻辑,进行删除,就可能删除的是B的分布式锁


finally {
  if (stringRedisTemplate.opsForValue().get(key).equals(value)) {
      stringRedisTemplate.delete(key);
  }
}

⑦. 基于⑥的操作也有问题,finally块的判断+del删除操作不是原子性的


REDIS09_分布式锁的概述、加锁使用sexnu、解锁使用lua脚本保证原子性、引发的问题思考（四）



⑧. 用Lua脚本,删除保证原子性


   //1.占分布式锁,去redis占坑  setIfAbsent==sexnx
   //Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock", "111");
   //redisTemplate.expire("lock",30,TimeUnit.SECONDS);
   String uuid = UUID.randomUUID().toString();
   Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock", uuid,300,TimeUnit.SECONDS);
   if(lock){
       Map<String, List<Catelog2Vo>> dataFromDb=null;
       try{
           //加锁成功,执行业务
           dataFromDb = getDataFromDb();
       }finally {
           //原子删锁
           String script = "if redis.call('get', KEYS[1]) == ARGV[1] " +
                   "then " +
                   "return redis.call('del', KEYS[1]) " +
                   "else " +
                   "   return 0 " +
                   "end";
           //删除成功返回1,删除不成功返回0
           redisTemplate.execute(
                   new DefaultRedisScript<Long>(script,Long.class),
                   Arrays.asList("lock"),uuid);
       }
       return dataFromDb;
   }else{
       //加锁失败....重试
       try { TimeUnit.SECONDS.sleep(1);  } catch (InterruptedException e) {e.printStackTrace();}
       return getCatalogJsonFromDbWithRedisLock();
   }


上一篇：给定公历日期计算12星座（Java代码实现）


下一篇：JQUERY 动态时钟