Redis分布式锁解锁案例讲解

Posted 2021-12-04 link可

Redis分布式锁解锁案例

相关视频教程（来自动力节点）：https://www.bilibili.com/video/BV1Uz4y1X72A

相关资料下载：http://www.bjpowernode.com/?51cto

1、解锁代码

还是先展示代码，再带大家慢慢解释为什么这样实现：

public class RedisTool {
    private static final Long RELEASE_SUCCESS = 1L;
    /**
     * 释放分布式锁
     * @param jedis Redis客户端
     * @param lockKey 锁
     * @param requestId 请求标识
     * @return 是否释放成功
     */


    public static boolean releaseDistributedLock(Jedis jedis, String lockKey, String requestId) {


        String script = "if redis.call(get, KEYS[1]) == ARGV[1] then return redis.call(del, KEYS[1]) else return 0 end";


        Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));


        if (RELEASE_SUCCESS.equals(result)) {


            return true;


        }


        return false;


    }


}

可以看到，我们解锁只需要两行代码就搞定了！第一行代码，我们写了一个简单的Lua脚本代码，上一次见到这个编程语言还是在《黑客与画家》里，没想到这次居然用上了。第二行代码，我们将Lua代码传到jedis.eval()方法里，并使参数KEYS[1]赋值为lockKey，ARGV[1]赋值为requestId。eval()方法是将Lua代码交给Redis服务端执行。

那么这段Lua代码的功能是什么呢？

其实很简单，首先获取锁对应的value值，检查是否与requestId相等，如果相等则删除锁（解锁）。那么为什么要使用Lua语言来实现呢？因为要确保上述操作是原子性的。那么为什么执行eval()方法可以确保原子性，源于Redis的特性，下面是官网对eval命令的部分解释：

简单来说，就是在eval命令执行Lua代码的时候，Lua代码将被当成一个命令去执行，并且直到eval命令执行完成，Redis才会执行其他命令。

2、错误示例1

最常见的解锁代码就是直接使用jedis.del()方法删除锁，这种不先判断锁的拥有者而直接解锁的方式，会导致任何客户端都可以随时进行解锁，即使这把锁不是它的。

public static void wrongReleaseLock1(Jedis jedis, String lockKey) {


    jedis.del(lockKey);


}

3、错误示例2

这种解锁代码乍一看也是没问题，甚至我之前也差点这样实现，与正确姿势差不多，唯一区别的是分成两条命令去执行，代码如下：

public static void wrongReleaseLock2(Jedis jedis, String lockKey, String requestId) {


    // 判断加锁与解锁是不是同一个客户端


    if (requestId.equals(jedis.get(lockKey))) {


        // 若在此时，这把锁突然不是这个客户端的，则会误解锁


        jedis.del(lockKey);


    }


}

如代码注释，问题在于如果调用jedis.del()方法的时候，这把锁已经不属于当前客户端的时候会解除他人加的锁。那么是否真的有这种场景？答案是肯定的，比如客户端A加锁，一段时间之后客户端A解锁，在执行jedis.del()之前，锁突然过期了，此时客户端B尝试加锁成功，然后客户端A再执行del()方法，则将客户端B的锁给解除了。

4、怎么保证锁时间大于业务执行时间？

redis里面有一个看门狗的机制，其实可以根据这个思路来，加锁成功后，启动一条守护线程，守护线程给锁进行无限续期！当锁不存在的时候就跳过，存在就续期，可以保证锁的时间大于业务时间！线程为守护线程的原因是，守护线程依赖于主线程，当主线程挂了之后，守护线程也会挂掉！这样能避免程序宕机之后，续期的线程依旧续期，造成死锁！

5、总结

本文主要介绍了如何使用Java代码正确实现Redis分布式锁，对于加锁和解锁也分别给出了两个比较经典的错误示例。其实想要通过Redis实现分布式锁并不难，只要保证能满足可靠性里的四个条件。互联网虽然给我们带来了方便，只要有问题就可以google，然而网上的答案一定是对的吗？其实不然，所以我们更应该时刻保持着质疑精神，多想多验证。

如果你的项目中Redis是多机部署的，那么可以尝试使用Redisson实现分布式锁。