Lua脚本保证删除的原子性
使用redis实现分布式锁
1.设置锁的过期时间
2.使用UUID防误删
(1)情景实现:
在上锁后A操作的过程中,由于特殊情况导致操作停滞导致此过期而解开并发的操作,B拿到锁之后操作,此时A操作恢复正常,执行解锁操作解开此锁,导致了的误删问题。
(2)使用 UUID 来解决:
使用 uuid 来标识不同的操作 其实就是 锁的value set lock uuid nx ex 800
释放锁的时候 判断当前的 uuid 和要释放锁的 uuid 是否相同,不一样就不释放
有问题:操作缺乏原子性
解决:使用lua脚本保证删除的原子性
3.使用LUA脚本保证删除的原子性
情景实现:
A在比较完 uuid 准备进行删除的时候,到期导致自动释放,同时B抢到了这把锁,而A继续实行删除 的操作,因此导致了的误删问题。
lua脚本防止删除持有过期锁的客户端误删现有锁的情况出现
if redis.call(get, KEYS[1]) == ARGV[1] then return redis.call(del, KEYS[1]) else return 0 end
keys[1]:获取锁时输入的key,即资源名; argv[1]:即是获取锁输入时的value,由于ARGV[1]的唯一性,则不会出现误删其他线程的锁。
@Override public void testLock() { // 设置uuId String uuid = UUID.randomUUID().toString(); //UUID.randomUUID().toString()是javaJDK提供的一个自动生成主键的方法 // 缓存的lock 对应的值 ,应该是index2 的uuid Boolean flag = redisTemplate.opsForValue().setIfAbsent("lock", uuid,1, TimeUnit.SECONDS); // 判断flag index=1 if (flag){ // 说明上锁成功! 执行业务逻辑 String value = redisTemplate.opsForValue().get("num"); // 判断 if(StringUtils.isEmpty(value)){ return; } // 进行数据转换 int num = Integer.parseInt(value); // 放入缓存 redisTemplate.opsForValue().set("num",String.valueOf(++num)); // 定义一个lua 脚本 String script = "if redis.call(get, KEYS[1]) == ARGV[1] then return redis.call(del, KEYS[1]) else return 0 end"; // 准备执行lua 脚本 DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>(); // 将lua脚本放入DefaultRedisScript 对象中 redisScript.setScriptText(script); // 设置DefaultRedisScript 这个对象的泛型 redisScript.setResultType(Long.class); // 执行删除 redisTemplate.execute(redisScript, Arrays.asList("lock"),uuid); }else { // 没有获取到锁! try { Thread.sleep(1000); // 睡醒了之后,重试 testLock(); } catch (InterruptedException e) { e.printStackTrace(); } } }
·