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

·

经验分享 程序员 微信小程序 职场和发展