Redis魔法:点燃分布式锁的奇妙实现

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 Tair(兼容Redis),内存型 2GB
简介: Redis魔法:点燃分布式锁的奇妙实现

分布式锁是一种用于在分布式系统中控制对共享资源的访问的锁。它与传统的单机锁不同,因为它需要在多个节点之间协调以确保互斥访问。

本文将介绍什么是分布式锁,以及使用Redis实现分布式锁的几种方案。

一、前言

了解分布式锁之前,需要先了解一下

  • 线程锁
  • 进程锁
  • CAP理论

线程锁

线程锁主要用来给方法、代码块加锁。

当某个方法或代码使用锁,在同一时刻仅有一个线程执行该方法或该代码段。

线程锁只在同一JVM中有效果,因为线程锁的实现,是通过线程之间共享内存实现的,

一般实现方法:

  • Synchronized
  • Lock

进程锁

进程锁是控制同一操作系统中多个进程访问某个共享资源

进程具有独立性,各个进程无法访问其他进程的资源,因此无法通过synchronized等线程锁实现进程锁。

CAP理论

任何一个分布式系统都无法同时满足

  • 一致性(Consistency)
  • 可用性(Availability)
  • 分区容错性(Partition tolerance)

最多只能同时满足两项。

二、分布式锁

概念

如果不同的系统或同一个系统的不同主机之间共享了某个临界资源,往往需要互斥来防止彼此干扰,以保证一致性,就产生了分布式锁。包含三个要素:

  • 分布式系统
  • 不同进程
  • 共同访问共享资源

分布式锁,实现的是CA,即一致性可用性

特性

  • 互斥性: 任意时刻,只有一个客户端能持有锁。
  • 锁超时释放:持有锁超时,可以释放,防止不必要的资源浪费,也可以防止死锁。
  • 可重入性:一个线程如果获取了锁之后,可以再次对其请求加锁。
  • 高性能和高可用:加锁和解锁需要开销尽可能低,同时也要保证高可用,避免分布式锁失效。
  • 安全性:锁只能被持有的客户端删除,不能被其他客户端删除。

三、实现方案

Redisson框架

框架介绍

Redisson是一款基于Java的Redis客户端,它封装了Redis的Java客户端Jedis、Lettuce等,并且提供了许多额外的功能,例如分布式锁、分布式集合、分布式对象、布隆过滤器等。

框架特点
  1. 提供了丰富的API,简单易用。
  2. 提供了多种数据结构的实现,如分布式锁、分布式集合、分布式Map、分布式Queue等。
  3. 支持多种Redis部署方式,如单节点、主从、哨兵、集群等。
  4. 提供了基于Netty的高性能的Redis连接池。
  5. 提供了基于Ramp模型的分布式远程调用框架,可以方便的进行分布式服务调用。
简单示例

1.引入Redisson的依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.16.0</version>
</dependency>

2.创建RedissonClient对象

Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redissonClient = Redisson.create(config);

3.使用RedissonClient对象进行数据操作

// 获取字符串对象
RBucket<String> bucket = redissonClient.getBucket("myKey");
bucket.set("myValue");
// 获取Map对象
RMap<String, String> map = redissonClient.getMap("myMap");
map.put("key1", "value1");
// 获取分布式锁对象
RLock lock = redissonClient.getLock("myLock");
lock.lock();
try {
    // do something
} finally {
    lock.unlock();
}

基于SETNX命令实现

通过使用Redis中的SETNX命令(即SET if Not eXists),可以实现一个简单的分布式锁。

SETNX命令是Redis中的一种原子性操作,用于将一个键值对(key-value)设置到Redis中,仅在键不存在时才会设置成功,否则设置失败。利用SETNX命令的特性,可以实现分布式锁的机制,具体步骤如下:

  • 设置锁:在Redis中设置一个键值对,键为锁名称,值为一个随机生成的字符串,同时设置过期时间(防止锁一直存在,导致死锁)。可以使用以下Redis命令:
SETNX lock_name random_value
EXPIRE lock_name expire_time
  • 获取锁:如果SETNX命令返回1,则说明锁设置成功,此时获取到了锁;如果返回0,则说明锁已经被其他节点持有,此时需要等待一段时间后重试获取锁。
  • 释放锁:释放锁时,需要先判断当前线程持有的锁是否与之前设置的锁名称和值相同,如果相同,则通过DEL命令删除该键值对,释放锁。
if redis.call('get', KEYS[1]) == ARGV[1] then
    return redis.call('del', KEYS[1])
else
    return 0
end

基于RedLock实现

RedLock是一个多节点分布式锁算法,它基于Redis和一些简单的算法来实现高可用的分布式锁。

与传统的Redis分布式锁方案相比,RedLock可以更好地应对网络故障和硬件故障等异常情况,提高系统的可用性和稳定性。

RedLock算法的基本思想是:将锁的持有和释放过程转化为一个竞争资源的问题,通过多节点协作的方式来实现锁的分配和释放。

具体步骤如下:

  1. 对于要加锁的资源,计算出一个唯一的标识(比如使用hash函数将资源名称转化为一个32位整数),作为锁的名称。
  2. 获取多个Redis节点的当前时间戳,并计算出一个时钟偏差(clock drift)。时钟偏差可以通过取多个Redis节点的时间戳的平均值来计算。这样可以避免不同Redis节点之间的时间不同步而导致的锁冲突问题。
  3. 获取锁:对于每个Redis节点,尝试通过SET命令获取锁。如果获取锁成功,则记录锁的名称、锁的值(一个随机字符串)、过期时间以及Redis节点的标识信息(比如IP地址和端口号)。如果获取锁失败,则记录失败的节点信息。
  4. 判断获取锁的结果:统计获取锁成功的节点数,并根据Quorum算法(投票算法)来判断是否获取锁成功。如果获取锁成功的节点数大于等于N/2+1(其中N为Redis节点数),则表示锁获取成功;否则,表示锁获取失败。
  5. 执行结果:如果锁获取成功,则执行相应的业务逻辑;如果锁获取失败,则需要尝试在所有失败的节点中找到一个最新的锁并释放它,以避免死锁问题。
  6. 释放锁:释放锁时,需要根据锁的名称和值来判断当前节点是否持有该锁。如果当前节点持有该锁,则通过DEL命令删除该键值对,释放锁。

需要注意的是,RedLock算法并不能保证绝对的可用性和正确性,仍然可能存在某些特殊情况下的锁冲突问题。

因此,在实际应用中,需要根据具体业务场景和需求来选择适合的分布式锁方案,并进行充分的测试和优化。

基于Lua脚本实现

在Redis中可以使用Lua脚本来实现分布式锁,其基本思想是通过原子操作将锁的获取和释放过程合并为一个操作,保证锁的原子性和一致性。

使用Lua脚本可以在Redis中实现一个基于SET命令的分布式锁,具体实现步骤如下:

  1. 生成一个随机字符串作为锁的值,以确保不同的客户端使用的锁值不同。
  2. 使用SET命令将锁名作为key,锁值作为value,过期时间作为expire参数来设置锁,加上NX(Not eXist)选项,只有当key不存在时才设置成功。
  3. 在Lua脚本中使用eval命令执行以下脚本:
if redis.call('set', KEYS[1], ARGV[1], 'NX', 'PX', ARGV[2]) then
    return 1
else
    return 0
end

其中,KEYS[1]表示锁的名称,ARGV[1]表示锁的值,ARGV[2]表示锁的过期时间。

  1. 结果:如果eval命令返回1,则表示获取锁成功;如果返回0,则表示获取锁失败。
  2. 释放锁时,可以使用DEL命令删除锁的名称即可。

下面是一个完整的Lua例子:

if redis.call('setnx', KEYS[1], ARGV[1]) == 1 then
    redis.call('expire', KEYS[1], ARGV[2])
    return 1
else
    return 0
end
-- 释放锁
if redis.call('get', KEYS[1]) == ARGV[1] then
    return redis.call('del', KEYS[1])
else
    return 0
end

上面的代码包括两个部分:获取锁和释放锁。

  • 获取锁:使用setnx命令来尝试获取锁。如果获取成功,则设置锁的过期时间,并返回1表示获取锁成功;否则,返回0表示获取锁失败。
  • 释放锁:先通过get命令获取锁的值,判断当前节点是否持有该锁。如果持有,则使用del命令删除该键值对并返回1表示释放锁成功;否则,返回0表示释放锁失败。

四、总结

上面提到的通过Redis实现的分布式锁几种方案,在高并发的情况下,可能存在锁冲突的问题,因此需要根据实际业务场景来选择适合的锁方案,并进行充分的测试和优化。

最后,推荐一款应用开发神器

扯个嗓子!关于目前低代码在技术领域很活跃!

低代码是什么?一组数字技术工具平台,能基于图形化拖拽、参数化配置等更为高效的方式,实现快速构建、数据编排、连接生态、中台服务等。通过少量代码或不用代码实现数字化转型中的场景应用创新。它能缓解甚至解决庞大的市场需求与传统的开发生产力引发的供需关系矛盾问题,是数字化转型过程中降本增效趋势下的产物。

这边介绍一款好用的低代码平台——JNPF快速开发平台。近年在市场表现和产品竞争力方面表现较为突出,采的是最新主流前后分离框架(SpringBoot+Mybatis-plus+Ant-Design+Vue3)。代码生成器依赖性低,灵活的扩展能力,可灵活实现二次开发。

以JNPF为代表的企业级低代码平台为了支撑更高技术要求的应用开发,从数据库建模、Web API构建到页面设计,与传统软件开发几乎没有差异,只是通过低代码可视化模式,减少了构建“增删改查”功能的重复劳动,还没有了解过低代码的伙伴可以尝试了解一下。

应用:https://www.jnpfsoft.com/?csdn

有了它,开发人员在开发过程中就可以轻松上手,充分利用传统开发模式下积累的经验。所以低代码平台对于程序员来说,有着很大帮助。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
1月前
|
NoSQL Java Redis
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
Redis分布式锁在高并发场景下是重要的技术手段,但其实现过程中常遇到五大深坑:**原子性问题**、**连接耗尽问题**、**锁过期问题**、**锁失效问题**以及**锁分段问题**。这些问题不仅影响系统的稳定性和性能,还可能导致数据不一致。尼恩在实际项目中总结了这些坑,并提供了详细的解决方案,包括使用Lua脚本保证原子性、设置合理的锁过期时间和使用看门狗机制、以及通过锁分段提升性能。这些经验和技巧对面试和实际开发都有很大帮助,值得深入学习和实践。
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
|
9天前
|
NoSQL Redis
Redis分布式锁如何实现 ?
Redis分布式锁通过SETNX指令实现,确保仅在键不存在时设置值。此机制用于控制多个线程对共享资源的访问,避免并发冲突。然而,实际应用中需解决死锁、锁超时、归一化、可重入及阻塞等问题,以确保系统的稳定性和可靠性。解决方案包括设置锁超时、引入Watch Dog机制、使用ThreadLocal绑定加解锁操作、实现计数器支持可重入锁以及采用自旋锁思想处理阻塞请求。
43 16
|
1月前
|
缓存 NoSQL Java
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
59 3
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
|
1月前
|
NoSQL Redis 数据库
计数器 分布式锁 redis实现
【10月更文挑战第5天】
48 1
|
1月前
|
NoSQL 算法 关系型数据库
Redis分布式锁
【10月更文挑战第1天】分布式锁用于在多进程环境中保护共享资源,防止并发冲突。通常借助外部系统如Redis或Zookeeper实现。通过`SETNX`命令加锁,并设置过期时间防止死锁。为避免误删他人锁,加锁时附带唯一标识,解锁前验证。面对锁提前过期的问题,可使用守护线程自动续期。在Redis集群中,需考虑主从同步延迟导致的锁丢失问题,Redlock算法可提高锁的可靠性。
74 4
|
1月前
|
缓存 NoSQL Ubuntu
大数据-39 Redis 高并发分布式缓存 Ubuntu源码编译安装 云服务器 启动并测试 redis-server redis-cli
大数据-39 Redis 高并发分布式缓存 Ubuntu源码编译安装 云服务器 启动并测试 redis-server redis-cli
55 3
|
1月前
|
缓存 NoSQL 算法
面试题:Redis如何实现分布式锁!
面试题:Redis如何实现分布式锁!
|
3月前
|
NoSQL Redis
基于Redis的高可用分布式锁——RedLock
这篇文章介绍了基于Redis的高可用分布式锁RedLock的概念、工作流程、获取和释放锁的方法,以及RedLock相比单机锁在高可用性上的优势,同时指出了其在某些特殊场景下的不足,并提到了ZooKeeper作为另一种实现分布式锁的方案。
112 2
基于Redis的高可用分布式锁——RedLock
|
3月前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
这篇文章是关于如何在SpringBoot应用中整合Redis并处理分布式场景下的缓存问题,包括缓存穿透、缓存雪崩和缓存击穿。文章详细讨论了在分布式情况下如何添加分布式锁来解决缓存击穿问题,提供了加锁和解锁的实现过程,并展示了使用JMeter进行压力测试来验证锁机制有效性的方法。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
|
1月前
|
存储 缓存 NoSQL
大数据-38 Redis 高并发下的分布式缓存 Redis简介 缓存场景 读写模式 旁路模式 穿透模式 缓存模式 基本概念等
大数据-38 Redis 高并发下的分布式缓存 Redis简介 缓存场景 读写模式 旁路模式 穿透模式 缓存模式 基本概念等
62 4

热门文章

最新文章