单机redis分布式锁实现原理解析
最近我们有个服务经常出现存储的数据出现重复，首先上一个系统流程图：
用户通过http请求可以通知任务中心结束掉自己发送的任务，这时候任务中心会通过MQ通知结束服务去结束任务保存数据，由于任务结束数据计算保存有一定延时，所以存在用户短时间内多次结束同一个任务，这时候就会导致我们结束服务对同一个任务保存多次数据。恰好我们也是用了redis，所以对于这个问题我当时想到使用分布式锁来解决，那么如何用redis实现分布式锁呢？
首先要明确一个分布式锁应具备的原则：
互斥性。在任意时刻，只有一个客户端能持有锁；不会发生死锁。即使一个客户端持有锁的期间崩溃而没有主动释放锁，也需要保证后续其他客户端能够加锁成功；加锁和解锁必须是同一个客户端；有高可用的获取锁和释放锁功能。
由于我们只使用了单机的redis，所以本文的实现不具备第四点原则。
我们这个锁的实现就包括两点：加锁、解锁。首先看加锁。先上代码：
public boolean tryGetDistributedLock(String lockKey, String requestId, int expireTime) throws Exception{
Jedis jedis = null;
try {
jedis = getJedisClient();
String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);
if (LOCK_SUCCESS.equals(result)) {
return true;
}
return false;
} finally {
returnResource(jedis);
}
}
我们的加锁就是设置一个键值对，并且满足以下条件：
确保只有当键不存在时才设置有效；设置的值必须是当前客户端生成的uuid；键必须要有过期时间。
这三点条件就可以满足上述的原则1、原则2。
接下来看下解锁，代码如下：
public boolean releaseDistributedLock(String lockKey, String requestId) throws Exception{
Jedis jedis = null;
try {
jedis = getJedisClient();
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;
}finally {
returnResource(jedis);
}
}
解锁是通过一段lua脚本实现，逻辑如下：
1、获取锁键值看是否与当初设置的值一致；
2、如果一致则删除键。
由于解锁过程分为两步，为了确保原子性所以通过让redis执行lua脚本来实现，校验键值可以确保加锁解锁都是同一个客户端。
这样一个简易的分布式锁就实现完毕了，当然在本文开头就说了，这个实现只能满足单机redis的情况，对于redis集群其实是不严谨的，对于redis集群有一个redlock方案，我也在研究中，后面也会总结一下。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
ExecutorService Callable Future多线程返回结果原理解析
这篇文章主要为大家介绍了ExecutorService Callable Future多线程返回结果，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-09-09
这篇文章主要介绍了jdbc与druid连接池的使用详解,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-03-03
java获取当前时间和前一天日期的实现代码。需要的朋友可以过来参考下，希望对大家有所帮助2013-10-10
这篇文章主要为大家详细介绍了java使用poi导出Excel的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-08-08
这篇文章主要介绍了解决mybatis 执行mapper的方法时报空指针问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-07-07
死信队列是一种特殊的消息队列,用来存储无法被正常消费的消息,常被用来实现延迟处理,异常消息处理等,本文主要介绍了springboot中RabbitMQ死信队列的实现示例,感兴趣的可以了解一下2024-01-01
作为替代,Spring 官方已在 Spring 5 中引入了 WebClient 作为非阻塞式 Reactive HTTP 客户端,本文将通过样例演示如何使用 WebClient,希望对大家有所帮助2024-04-04
语法糖（Syntactic sugar），也叫做糖衣语法，是英国科学家发明的一个术语，通常来说使用语法糖能够增加程序的可读性，从而减少程序代码出错的机会.这篇文章主要介绍了Java 中的语法糖知识，需要的朋友可以参考下2020-12-12
springboot使用AOP+反射实现Excel数据的读取
本文主要介绍了springboot使用AOP+反射实现Excel数据的读取，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-01-01
今天小编就为大家分享一篇关于Java对类私有变量的暴力反射技术讲解，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2019-03-03
最新评论