Redis的分布式锁

Posted H.C

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Redis的分布式锁相关的知识,希望对你有一定的参考价值。

加锁
使用jedis.setnx()命令实现加锁,其中key是锁,value是锁的过期时间。
执行过程:

  • 通过setnx()方法尝试加锁,如果当前锁不存在,返回加锁成功。

  • 如果锁已经存在则获取锁的过期时间,和当前时间比较,如果锁已经过期,则设置新的过期时间,返回加锁成功。

public class SimpleRedisLock {    public static long hold_time = 3000;    public static ThreadLocal<String> expireHolder = new ThreadLocal<>();    public static void acquire(String lock){        //1.先尝试用setnx命令获取锁,key为参数lock,值为当前时间+要持有锁的时间hold_time
        while(jedis.setnx(lock, String.valueOf(System.currentTimeMillis() + hold_time)) == 0){            //2.如果获取失败,先watch lock key
            jedis.watch(lock);            //3.获取当前超时时间
            String expireTime = jedis.get(lock);            if(expireTime != null && Long.parseLong(expireTime) < System.currentTimeMillis()){                //4.如果超时时间小于当前时间,开事务准备更新lock值
                Transaction transaction = jedis.multi();
                Response<String> response = transaction.getSet(lock, String.valueOf(System.currentTimeMillis() + hold_time));                //5.步骤2设置了watch,如果lock的值被其他线程修改,不是执行事务中的命令
                if(transaction.exec() != null){
                    String oldExpire = response.get();                    if(oldExpire != null && Long.parseLong(expireTime) < System.currentTimeMillis()){                        //6.如果setget命令返回的值依然是过期时间,认为获取锁成功(加了watch之后,这里返回的应该一直是超时时间)
                        break;
                    }
                }
            }else{                //如果key未超时,解除watch
                jedis.unwatch();
            }
        }        //设置客户端超时时间
        expireHolder.set(jedis.get(lock));
    }    public static void release(String lock){        //比较客户端超时时间与lock值,判断是否还由自己持有锁
        if(jedis.get(lock).equals(expireHolder.get())){
            jedis.del(lock);
        }
        jedis.close();
    }

}

 

那么这段代码问题在哪里?

 

  • 由于是客户端自己生成过期时间,所以需要强制要求分布式下每个客户端的时间必须同步。

  • 当锁过期的时候,如果多个客户端同时执行jedis.getSet()方法,那么虽然最终只有一个客户端可以加锁,但是这个客户端的锁的过期时间可能被其他客户端覆盖。

  • 锁不具备拥有者标识,即任何客户端都可以解锁。
    更为严谨的做法如下:

  • public class Redis {    private static final String LOCK_SUCCESS = "OK";    private static final String SET_IF_NOT_EXIST = "NX";    private static final String SET_WITH_EXPIRE_TIME = "PX";    /**
         * 尝试获取分布式锁
         * @param jedis Redis客户端
         * @param lockKey 锁
         * @param requestId 客户端标识
         * @param expireTime 超期时间
         * @return 是否获取成功
         */
        public static boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {
    
            String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);        if (LOCK_SUCCESS.equals(result)) {            return true;
            }        return false;
    
        }
    
    }

    可以看到上面的set()方法,通过requestId解决了分布式下不同客户端时间不统一问题,通过超期时间解决了多次getset覆盖问题,通过解锁时判断requestId解决了任何客户端都可以解锁问题。

解锁
比如客户端A加锁,一段时间之后客户端A解锁,在执行jedis.del()之前,锁突然过期了,此时客户端B尝试加锁成功,然后客户端A再执行del()方法,则将客户端B的锁给解除了。

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;

    }

}

 

 

以上是关于Redis的分布式锁的主要内容,如果未能解决你的问题,请参考以下文章

redis 分布式锁

如何使用redis实现分布式锁功能?

Redis分布式锁的原理是啥?如何续期?

分布式锁用zookeeper还是redis好

Redis | 黑马点评 + 思维导图分布式锁

分布式锁--Redis秒杀(互斥锁)(一)