Lua是redis 2.6 版本最大的亮点,通过内嵌对Lua 环境的支持,Redis 解决了长久以来不能高效地处理CAS (check-and-set)命令的缺点,并且可以通过组合使用多个命令,轻松实现以前很难实现或者不能高效实现的模式。

public void testLock() {
        //  设置uuId
        String uuid = UUID.randomUUID().toString();
        //  缓存的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();
            }
        }
    }

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐