一道redis分布式锁详解

1. value设置为过期时间&＃xff0c;就要求各个客户端严格的时钟同步&＃xff0c;这就需要使用到同步时钟。即使有同步时钟&＃xff0c;分布式的服务器一般来说时间肯定是存在少许误差的。
2. 锁过期时&＃xff0c;使用 jedis.getSet虽然可以保证只有一个线程设置成功&＃xff0c;但是不能保证加锁和解锁为同一个客户端&＃xff0c;因为没有标志锁是哪个客户端设置的嘛。

错误解锁方式

解锁错误方式一

直接删除key

public static void wrongReleaseLock(Jedis jedis, String key) {//不是自己加锁的key&＃xff0c;也会被释放jedis.del(key);}

简单粗暴&＃xff0c;直接解锁&＃xff0c;但是不是自己加锁的&＃xff0c;也会被删除&＃xff0c;这好像有点太随意了吧&＃xff01;

解锁错误方式二

判断自己是不是锁的持有者&＃xff0c;如果是&＃xff0c;则只有持有者才可以释放锁。

public static void wrongReleaseLock(Jedis jedis, String key, String uniqueId) {if (uniqueId.equals(jedis.get(key))) {// 如果这时锁过期自动释放&＃xff0c;又被其他线程加锁&＃xff0c;该线程就会释放不属于自己的锁jedis.del(key);}}

看起来很完美啊&＃xff0c;但是如果你判断的时候锁是自己持有的&＃xff0c;这时锁超时自动释放了。然后又被其他客户端重新上锁&＃xff0c;然后当前线程执行到jedis.del(key)&＃xff0c;这样这个线程不就删除了其他线程上的锁嘛&＃xff0c;好像有点乱套了哦&＃xff01;

正确加锁释放锁方式

基本上避免了以上几种错误方式之外&＃xff0c;就是正确的方式了。要满足以下几个条件&＃xff1a;

1. 命令必须保证互斥
2. 设置的key必须要有过期时间&＃xff0c;防止崩溃时锁无法释放
3. value使用唯一id标志每个客户端&＃xff0c;保证只有锁的持有者才可以释放锁

加锁直接使用set命令同时设置唯一id和过期时间&＃xff1b;其中解锁稍微复杂些&＃xff0c;加锁之后可以返回唯一id&＃xff0c;标志此锁是该客户端锁拥有&＃xff1b;释放锁时要先判断拥有者是否是自己&＃xff0c;然后删除&＃xff0c;这个需要redis的lua脚本保证两个命令的原子性执行。 下面是具体的加锁和释放锁的代码&＃xff1a;

&＃64;Slf4j
public class RedisDistributedLock {private static final String LOCK_SUCCESS &＃61; "OK";private static final Long RELEASE_SUCCESS &＃61; 1L;private static final String SET_IF_NOT_EXIST &＃61; "NX";private static final String SET_WITH_EXPIRE_TIME &＃61; "PX";// 锁的超时时间private static int EXPIRE_TIME &＃61; 5 * 1000;// 锁等待时间private static int WAIT_TIME &＃61; 1 * 1000;private Jedis jedis;private String key;public RedisDistributedLock(Jedis jedis, String key) {this.jedis &＃61; jedis;this.key &＃61; key;}// 不断尝试加锁public String lock() {try {// 超过等待时间&＃xff0c;加锁失败long waitEnd &＃61; System.currentTimeMillis() &＃43; WAIT_TIME;String value &＃61; UUID.randomUUID().toString();while (System.currentTimeMillis() }

单是一个redis的分布式锁就有这么多道道&＃xff0c;不知道你是否看明白了&＃xff1f;留言讨论下吧&＃xff01;

更多java高级学习课程资料&＃xff0c;java课件&＃xff0c;源码&＃xff0c;安装包等小编已经整理打包好&＃xff01;需要学习的小伙伴点赞私信回复学习即可免费领取&＃xff01;