redis如何实现分布式锁
mhr18 2024-12-02 17:34 15 浏览 0 评论
什么是分布式锁
分布式锁是一种用于在分布式系统中控制对共享资源的访问的锁。它与传统的单机锁不同,因为它需要在多个节点之间协调以确保互斥访问。
分布式锁的一些特点包括:
- 依赖于外部存储系统:分布式锁需要依赖于一个外部的存储系统来实现锁的状态共享。例如,可以使用Redis、ZooKeeper或数据库来实现分布式锁。
- 容错性:分布式锁需要具有容错性,以便在发生故障时能够快速恢复。
- 高可用性:分布式锁需要具有高可用性,以避免对业务造成影响。
- 跨进程:分布式锁可以跨越多个进程或节点,以实现对共享资源的互斥访问。
接下来锁它的使用:
- 一:SETNX + EXPIRE
- 二:使用Lua脚本(包含SETNX + EXPIRE两条指令)
- 三:SET的扩展命令(SET EX PX NX)
- 四: 开源框架~Redisson
- 五:多机实现的分布式锁Redlock红锁
方案一:SETNX+EXPIRE
在早期的Redis版本中,可以使用SETNX和EXPIRE命令来实现分布式锁。具体操作如下:
- 使用SETNX命令创建一个锁。SETNX命令会尝试设置一个key,如果key不存在,那么设置成功并返回1,如果key已存在,那么设置失败并返回0。例如,我们可以尝试获取一个名为"lock"的锁,可以使用如下命令: SETNX lock 1
- 如果上一步设置成功,那么表示我们已经获取到了锁。为了防止锁无法被释放,我们需要为锁设置一个超时时间,可以使用EXPIRE命令: EXPIRE lock 30
这个命令会设置"lock"这个key在30秒后过期。这样就避免了因为持有锁的进程崩溃导致的锁无法释放的问题。 - 当我们不再需要锁的时候,可以使用DEL命令来删除这个锁: DEL lock
然而,这种方式有一个问题,那就是SETNX和EXPIRE两个操作并不是原子的。如果在这两个操作之间,进程崩溃,那么可能会出现永久的锁,也就是说,锁被设置了,但是没有设置超时时间,所以这个锁会一直存在,导致其他进程无法获取到锁。
为了解决这个问题,从Redis 2.6.12版本开始,Redis提供了一种新的命令,可以在设置key的同时设置超时时间,这个命令是SET,如下:
SET lock 1 NX PX 30000
这个命令在设置key的同时,设置了超时时间,这两个操作是原子的,所以不会出现上述问题。
NX和PX是Redis的SET命令的可选参数,它们可以用来实现分布式锁的功能。NX表示只在键不存在时才设置值,相当于SETNX命令;PX表示设置键的过期时间为毫秒数,相当于PSETEX命令。结合使用NX和PX参数,可以保证锁的互斥性和活跃性。
方案二:使用Lua脚本(包含SETNX + EXPIRE两条指令)
在Redis中,你可以使用Lua脚本将SETNX和EXPIRE两个操作打包在一起,从而实现原子性。以下是一个使用Lua脚本实现的例子:
local key = KEYS[1]
local value = ARGV[1]
local ttl = ARGV[2]
local lockSet = redis.call('setnx', key, value)
if lockSet == 1 then
redis.call('expire', key, ttl)
end
return lockSet
这段Lua脚本执行以下操作:
- 尝试使用SETNX命令设置一个锁。如果锁已经存在,那么SETNX命令会返回0,如果锁不存在,那么SETNX命令会返回1,并且设置锁的值为value。
- 如果上一步设置锁成功(即SETNX命令返回1),那么使用EXPIRE命令设置锁的过期时间。过期时间是ttl。
- 最后,返回SETNX命令的结果。如果结果为1,那么表示成功获取到了锁,如果结果为0,那么表示获取锁失败。
在Redis客户端中,你可以这样调用这个Lua脚本:
EVAL <lua_script> 1 lock_key lock_value lock_ttl
其中,<lua_script>是上述Lua脚本,1是键的数量,lock_key是锁的键,lock_value是锁的值,lock_ttl是锁的过期时间。
这样,SETNX和EXPIRE两个操作就成为了一个原子操作,不会出现在两个操作之间进程崩溃导致的问题。
方案三:SET的扩展命令(SET EX PX NX)
Redis的SET命令在2.6.12及更高版本中被扩展,可以接收更多的参数,这些参数可以设置key的过期时间和当key不存在时才进行设置的条件,这就为我们实现分布式锁提供了便利。
SET命令的使用格式如下:
SET key value [EX seconds|PX milliseconds] [NX|XX]
这些选项的含义如下:
- EX seconds:设置键的过期时间为seconds秒。Redis会自动删除过期的key。
- PX milliseconds:设置键的过期时间为milliseconds毫秒。这是EX的另一种形式,允许你以更精细的时间粒度设置过期时间。
- NX:只在键不存在时,才对键进行设置操作。SETNX命令的功能就是这个选项提供的。
- XX:只在键已经存在时,才对键进行设置操作。
因此,你可以用以下命令在Redis中实现一个分布式锁:
SET lock_key lock_value PX 30000 NX
这个命令尝试设置一个名为lock_key的锁,锁的值是lock_value,过期时间是30000毫秒(30秒),只有当lock_key不存在时(即没有其他进程持有锁),才会设置成功。如果设置成功,命令返回"OK",你就可以进行需要同步的操作了。如果设置失败,命令返回nil,你就知道你没有获取到锁。
这个命令将获取锁、设置锁的值和设置锁的过期时间这三个操作打包在一起,作为一个原子操作,从而避免了在这些操作之间进程崩溃可能导致的问题。
方案四:开源框架~Redisson
Redisson是一个在Java中实现的Redis客户端,它提供了很多高级功能,包括分布式锁,信号量,队列等等。
在Redisson中,你可以很方便地使用分布式锁。以下是一个例子:
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
public class RedissonLockExample {
public static void main(String[] args) throws Exception {
// 创建RedissonClient实例
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);
// 获取锁
RLock lock = redisson.getLock("myLock");
// 上锁,同时设置锁过期时间为10秒,防止死锁
lock.lock(10, TimeUnit.SECONDS);
// 执行需要同步的业务代码
// ...
// 释放锁
lock.unlock();
// 关闭RedissonClient
redisson.shutdown();
}
}
Redisson的分布式锁实现了JDK的java.util.concurrent.locks.Lock接口,因此它可以作为Java的标准Lock对象来使用,这使得使用Redisson非常方便。
方案五:多机实现的分布式锁Redlock红锁
为什么要多机实现分布式锁?
- 容错性:如果使用单个Redis节点实现分布式锁,那么当这个节点宕机时,就无法使用锁了。而Redlock算法使用多个Redis节点,只要大多数节点是可用的,就可以正常使用锁。这提高了系统的可用性。
- 安全性:在某些情况下,使用单个Redis节点实现的分布式锁可能出现安全问题。例如,如果在获取锁和设置锁过期时间之间,进程崩溃了,那么可能出现锁永远无法释放的情况。虽然可以通过Lua脚本或者SET命令的扩展参数解决这个问题,但是在网络分区等复杂情况下,还可能存在其他安全问题。而Redlock算法考虑了这些问题,提供了更为安全的保障。
使用:
public static void main(String[] args) throws Exception {
// 创建RedissonClient实例
Config config1 = new Config();
config1.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson1 = Redisson.create(config1);
Config config2 = new Config();
config2.useSingleServer().setAddress("redis://127.0.0.1:6380");
RedissonClient redisson2 = Redisson.create(config2);
Config config3 = new Config();
config3.useSingleServer().setAddress("redis://127.0.0.1:6381");
RedissonClient redisson3 = Redisson.create(config3);
// 创建Redlock
RLock lock1 = redisson1.getLock("lockKey");
RLock lock2 = redisson2.getLock("lockKey");
RLock lock3 = redisson3.getLock("lockKey");
RedissonRedLock redLock = new RedissonRedLock(lock1, lock2, lock3);
// 尝试获取锁,同时设置锁过期时间为10秒,防止死锁
if (redLock.tryLock(10, 10, TimeUnit.SECONDS)) {
try {
// 执行需要同步的业务代码
// ...
} finally {
// 释放锁
redLock.unlock();
}
}
// 关闭RedissonClient
redisson1.shutdown();
redisson2.shutdown();
redisson3.shutdown();
}
难道这就完了么?
红锁存在的问题
红锁它通过在多个独立的 Redis 节点上同时执行 setnx 操作来实现加锁。如果大多数节点都加锁成功,那么整个红锁就算加锁成功。也就是说,如果成功设置锁的实例数 >= N/2 + 1,那么加锁成功 。
1、它不像zk有崩溃恢复,所以会产生脑裂,比如有五个节点A、B、C、D、E,线程1成功上锁了A、B、C,线程一成功加上了锁,现在节点C崩溃,线程二来了,那么他也能加上锁
2、红锁算法依赖于时间来计算锁的超时时间。如果存在时钟漂移,可能会导致锁的超时时间计算错误,从而影响到锁的正确性。例如,如果某个节点的时钟比其他节点快,那么它可能会认为锁已经超时并释放锁,而其他节点仍然认为锁是有效的。这种情况下,可能会出现多个客户端同时持有锁的情况。
相关推荐
- Java面试宝典之问答系列(java面试回答)
-
以下内容,由兆隆IT云学院就业部根据多年成功就业服务经验提供:1.写出从数据库表Custom中查询No、Name、Num1、Num2并将Name以姓名显示、计算出的和以总和显示的SQL。SELECT...
- ADG (Active Data Guard) 数据容灾架构下,如何配置 Druid 连接池?
-
如上图的数据容灾架构下,上层应用如果使用Druid连接池,应该如何配置,才能在数据库集群节点切换甚至主备数据中心站点切换的情况下,上层应用不需要变动(无需修改配置也无需重启);即数据库节点宕机/...
- SpringBoot多数据源dynamic-datasource快速入门
-
一、简介dynamic-datasourc是一个基于SpringBoot的快速集成多数据源的启动器,其主要特性如下:支持数据源分组,适用于多种场景纯粹多库读写分离一主多从混合模式。支持...
- SpringBoot项目快速开发框架JeecgBoot——项目简介及系统架构!
-
项目简介及系统架构JeecgBoot是一款基于SpringBoot的开发平台,它采用前后端分离架构,集成的框架有SpringBoot2.x、SpringCloud、AntDesignof...
- 常见文件系统格式有哪些(文件系统类型有哪几种)
-
PART.01常见文件系统格式有哪些常见的文件系统格式有很多,通常根据使用场景(Windows、Linux、macOS、移动设备、U盘、硬盘等)有所不同。以下是一些主流和常见的文件系统格式及其特点:一...
- Oracle MySQL Operator部署集群(oracle mysql group by)
-
以下是使用OracleMySQLOperator部署MySQL集群的完整流程及关键注意事项:一、部署前准备安装MySQLOperator通过Helm安装Operator到Ku...
- LibreOffice加入"转向Linux"运动
-
LibreOffice项目正准备削减部分Windows支持,并鼓励用户切换到Linux系统。自Oracle放弃OpenOffice后,支持和指导LibreOffice开发的文档基金会对未来有着明确的观...
- Oracle Linux 10发布:UEK 8.1、后量子加密、增强开发工具等
-
IT之家6月28日消息,科技媒体linuxiac昨日(6月27日)发布博文,报道称OracleLinux10正式发布,完全二进制兼容(binarycompatibility...
- 【mykit-data】 数据库同步工具(数据库同步工具 开源)
-
项目介绍支持插件化、可视化的数据异构中间件,支持的数据异构方式如下MySQL<——>MySQL(增量、全量)MySQL<——>Oracle(增量、全量)Oracle...
- oracle关于xml的解析(oracle读取xml节点的属性值)
-
有时需要在存储过程中处理xml,oracle提供了相应的函数来进行处理,xmltype以及相关的函数。废话少说,上代码:selectxmltype(SIConfirmOutput).extract...
- 如何利用DBSync实现数据库同步(通过dblink同步数据库)
-
DBSync是一款通用型的数据库同步软件,能侦测数据表之间的差异,能实时同步差异数据,从而使双方始终保持一致。支持各种数据库,支持异构同步、增量同步,且提供永久免费版。本文介绍其功能特点及大致用法,供...
- MYSQL存储引擎InnoDB(八十):InnoDB静态数据加密
-
InnoDB支持独立表空间、通用表空间、mysql系统表空间、重做日志和撤消日志的静态数据加密。从MySQL8.0.16开始,还支持为模式和通用表空间设置加密默认值,这允许DBA控制在这些模...
- JDK高版本特性总结与ZGC实践(jdk高版本兼容低版本吗)
-
美团信息安全技术团队核心服务升级JDK17后,性能与稳定性大幅提升,机器成本降低了10%。高版本JDK与ZGC技术令人惊艳,且JavaAISDK最低支持JDK17。本文总结了JDK17的主要...
- 4 种 MySQL 同步 ES 方案,yyds!(两个mysql数据库自动同步的方法)
-
本文会先讲述数据同步的4种方案,并给出常用数据迁移工具,干货满满!不BB,上文章目录:1.前言在实际项目开发中,我们经常将MySQL作为业务数据库,ES作为查询数据库,用来实现读写分离,...
- 计算机Java培训课程包含哪些内容?其实就这六大块
-
不知不觉秋天已至,如果你还处于就业迷茫期,不如来学习Java。对于非科班小白来说,Java培训会更适合你。提前了解下计算机Java培训课程内容,会有助于你后续学习。下面,我就从六个部分为大家详细介绍...
你 发表评论:
欢迎- 一周热门
- 最近发表
-
- Java面试宝典之问答系列(java面试回答)
- ADG (Active Data Guard) 数据容灾架构下,如何配置 Druid 连接池?
- SpringBoot多数据源dynamic-datasource快速入门
- SpringBoot项目快速开发框架JeecgBoot——项目简介及系统架构!
- 常见文件系统格式有哪些(文件系统类型有哪几种)
- Oracle MySQL Operator部署集群(oracle mysql group by)
- LibreOffice加入"转向Linux"运动
- Oracle Linux 10发布:UEK 8.1、后量子加密、增强开发工具等
- 【mykit-data】 数据库同步工具(数据库同步工具 开源)
- oracle关于xml的解析(oracle读取xml节点的属性值)
- 标签列表
-
- oracle位图索引 (74)
- oracle批量插入数据 (65)
- oracle事务隔离级别 (59)
- oracle 空为0 (51)
- oracle主从同步 (55)
- oracle 乐观锁 (51)
- redis 命令 (78)
- php redis (88)
- redis 存储 (66)
- redis 锁 (69)
- 启动 redis (66)
- redis 时间 (56)
- redis 删除 (67)
- redis内存 (57)
- redis并发 (52)
- redis 主从 (69)
- redis 订阅 (51)
- redis 登录 (54)
- redis 面试 (58)
- 阿里 redis (59)
- redis 搭建 (53)
- redis的缓存 (55)
- lua redis (58)
- redis 连接池 (61)
- redis 限流 (51)