单机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方案，我也在研究中，后面也会总结一下。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
SpringBoot整合WebSocket实现后端向前端发送消息的实例代码
WebSocket使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据,下面这篇文章主要给大家介绍了关于SpringBoot整合WebSocket实现后端向前端发送消息的相关资料,需要的朋友可以参考下2023-03-03
本篇文章主要介绍了java的poi技术读取和导入Excel实例，报表输出是Java应用开发中经常涉及的内容，有需要的可以了解一下。2016-11-11
Java两整数相除向上取整的方式详解(Math.ceil())
在调外部接口获取列表数据时,需要判断是否已经取完了所有的值,因此需要用到向上取整,下面这篇文章主要给大家介绍了关于Java两整数相除向上取整的相关资料,需要的朋友可以参考下2022-06-06
这篇文章主要介绍了Java中的RASP实现详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-08-08
本文主要介绍了一个多线程卖票的例子，通过卖票这个实例来介绍多线程的方式，加深理解,需要的朋友可以参考下2017-09-09
springboot2如何禁用自带tomcat的session功能
这篇文章主要介绍了springboot2如何禁用自带tomcat的session功能，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-11-11
Spring Boot中除了对常用的关系型数据库提供了优秀的自动化支持之外，对于很多NoSQL数据库一样提供了自动化配置的支持。本篇文章主要介绍了Spring Boot中Redis的使用实例代码，有兴趣的开业了解一下。2017-04-04
这篇文章主要介绍了简单了解SpringCloud运行原理,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-11-11
本文主要介绍了浅谈Java几种文件读取方式耗时，主要介绍了4种，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-04-04
这篇文章主要为大家详细介绍了Java WEB过滤器的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-08-08
最新评论