③. 为何要使用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释放锁
④. 部署了微服务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删除操作不是原子性的
⑧. 用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(); }
