【Redis从头学-16】分析分布式锁中存在的坑,学会如何设计Redis分布式锁

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: 【Redis从头学-16】分析分布式锁中存在的坑,学会如何设计Redis分布式锁

🌟前言


Redis分布式锁作为非常重要的知识点,在工作或者面试中是必不可少的。经过一段时间的学习,本文就带大家分析分布式锁中存在的坑,学会如何设计Redis分布式锁。


🌟什么是分布式锁


在单机架构中,解决线程安全问题的方案是单机锁,这种锁只能锁当前进程。在分布式结构下,是不能解决线程安全问题的,所以引入了分布式锁的概念来作为中央管理锁,通过中央管理锁来管理各个线程的权限以此来解决线程安全问题,保证同一时刻同一客户端只能有一个线程操作共享资源这个中央管理锁也就是分布式锁,通常分布式锁可以由Redis、Zookeeper实现。


这个就类似于在单机架构中实现token认证很容易,但是在分布式结构下实现token认证就要解决所有服务器的一致性问题,那就引入了中央token认证服务器来统一管理分布式中的token。


通过对以上两个问题的理解,解决分布式下线程安全问题与token认证问题,都使用了中央管理的思想。


🌟如何设计分布式锁


上一节知道了使用Redis分布式锁来解决线程安全问题,那么你知道如何设计一个分布式锁吗?


  1. 互斥性。在分布式架构中,要保证同一时刻同一个线程只能在一台客户端操作共享资源。
  2. 系统容错性或者锁释放。锁要及时释放,避免其他线程获取不到锁导致系统崩溃。
  3. 可重入性。同一线程内,外层函数获得锁之后,内层递归函数仍然可以获取到该锁。防止同一线程重复获取锁。
  4. 锁归属。防止线程误删其他线程锁。


🌟死锁问题


SETNX:如果redis中存在当前键,则不创建返回0;不存在,则创建返回1。


使用SETNX+EXPIRE组合来实现Redis分布式锁。使用SETNX加锁,之后使用EXPIRE设置锁过期时间,释放锁时采用DEL命令释放。


问题分析

原子性无法保证造成死锁问题:加锁时,由两条指令进行组合,而Redis每条指令是原子性的,多条指令并不能保证原子性。假如,执行完前置指令SETNX后中途出现异常导致EXPIRE命令无法执行或者导致DEL无法执行,是不是就能导致锁永不过期或者无法释放。这就造成了其他线程无法再获取到锁,也就是死锁问题。


生活场景分析:某不知名旅游景点公共卫生间坑位(共享资源)紧张只能保证一人上厕所且每人只能上10分钟(同一时刻同一线程),游客上厕所需要提前刷厕所外的入厕卡(锁),结束之后需要再次刷卡。假如,小明得到了卡,但是他今天拉肚子或者便秘,进去了十分钟还没有结束,公共卫生间外边的人越来越多就会导致旅游景点瘫痪。(死锁)


问题总结

原子性问题、锁得不到释放造成的死锁问题。


伪代码

//加锁
boolean flag=setnx(key,value);
//是否获取到锁
if(flag){
    //设置过期时间
    expire(key,30,Timeout.seconds);
   try{
       //业务逻辑
   }finally{
       del(key);
   }
}else{
    //继续获取锁
}


🌟锁误删除问题、锁过期释放问题


因为存在原子性引发的死锁问题。恰巧Redis中的SET key value [EX seconds] [PX milliseconds] [NX|XX]是一个原子命令,它可以设置key的同时,设置过期时间。


问题分析

锁误删除问题:虽然解决了原子性无法保证引发的死锁问题,但是想一想锁的过期时间与线程处理能力能否匹配的问题。假如,线程A正在处理业务,由于网络原因或者本身处理能力导致业务没有处理完,锁就过期自动释放了。此时,线程B尝试获取锁,正好获取到了锁,而这时线程A处理完业务手动释放了锁,但是这个锁是线程B的啊。是不是问题就来了!


场景分析

还按上述的例子。公示了新的入厕规定。此时公共卫生间外设计一个按钮,入厕时需要按一下这个按钮,按钮按下显示倒计时,10分钟过后时间重置为0或者由入厕者结束后按下重置为0。假如,小明进去上厕所但是因为便秘十分钟还没结束,这时厕所外倒计时已经为0,小李这时一看倒计时为0便按下按钮进去了,恰好这时小明结束出来了直接按了按钮,倒计时瞬间清0,那不是小李按的吗?


问题总结

锁误删问题、锁过期问题、加锁设置过期时间和删除锁是非原子性


伪代码

//加锁
boolean flag=set(key,value);--setIfabsent
//是否获取到锁
if(flag){
    //设置过期时间
    expire(key,30,Timeout.seconds);
   try{
       //业务逻辑
   }finally{
       del(key);
   }
}else{
    //继续获取锁
}


🌟加锁和释放锁非原子性问题


上一节中分析了相关问题在于没有区分锁归谁的问题以及加锁和释放锁非原子性问题。这里使用Lua脚本来解决。


问题分析

虽然这个方法可以解决锁误删问题,但是并没有解决锁过期但是业务没有执行完的问题。想要解决锁过期问题,可以了解Redisson框架中的看门狗机制。


伪代码

//获取用户id
String userId=User.getId();
key="lock";
//加锁
boolean flag=set(key,value);--setIfabsent
//lua脚本
String script = "if redis.call('get',KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end ";
//是否获取到锁
if(flag){
    //设置过期时间
    expire(key,30,Timeout.seconds);
   try{
       //业务逻辑
   }finally{
       //结合lua脚本释放锁
       Long result= stringRedisTemplate.execute(new DefaultRedisScript<>(script,Long.class),
                       Arrays.asList(key),userId);
   }
}else{
    //继续获取锁
}


🌟总结


通过上述存在的问题分析,可以得出在设计分布式锁时要学会如何避免死锁问题、锁误删问题、加锁和设置过期时间以及释放锁间的原子性问题、锁的自动续期问题。


🌟写在最后


有关于分析分布式锁中存在的坑,学会如何设计Redis分布式锁到此就结束了。感谢大家的阅读,希望大家在评论区对此部分内容散发讨论,便于学到更多的知识。


相关实践学习
基于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
目录
相关文章
|
14天前
|
存储 NoSQL Java
使用lock4j-redis-template-spring-boot-starter实现redis分布式锁
通过使用 `lock4j-redis-template-spring-boot-starter`,我们可以轻松实现 Redis 分布式锁,从而解决分布式系统中多个实例并发访问共享资源的问题。合理配置和使用分布式锁,可以有效提高系统的稳定性和数据的一致性。希望本文对你在实际项目中使用 Redis 分布式锁有所帮助。
40 5
|
17天前
|
NoSQL Java 数据处理
基于Redis海量数据场景分布式ID架构实践
【11月更文挑战第30天】在现代分布式系统中,生成全局唯一的ID是一个常见且重要的需求。在微服务架构中,各个服务可能需要生成唯一标识符,如用户ID、订单ID等。传统的自增ID已经无法满足在集群环境下保持唯一性的要求,而分布式ID解决方案能够确保即使在多个实例间也能生成全局唯一的标识符。本文将深入探讨如何利用Redis实现分布式ID生成,并通过Java语言展示多个示例,同时分析每个实践方案的优缺点。
34 8
|
1月前
|
NoSQL Redis
Redis分布式锁如何实现 ?
Redis分布式锁通过SETNX指令实现,确保仅在键不存在时设置值。此机制用于控制多个线程对共享资源的访问,避免并发冲突。然而,实际应用中需解决死锁、锁超时、归一化、可重入及阻塞等问题,以确保系统的稳定性和可靠性。解决方案包括设置锁超时、引入Watch Dog机制、使用ThreadLocal绑定加解锁操作、实现计数器支持可重入锁以及采用自旋锁思想处理阻塞请求。
55 16
|
27天前
|
缓存 NoSQL PHP
Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出
本文深入探讨了Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出。文章还介绍了Redis在页面缓存、数据缓存和会话缓存等应用场景中的使用,并强调了缓存数据一致性、过期时间设置、容量控制和安全问题的重要性。
37 5
|
2月前
|
NoSQL Java Redis
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
Redis分布式锁在高并发场景下是重要的技术手段,但其实现过程中常遇到五大深坑:**原子性问题**、**连接耗尽问题**、**锁过期问题**、**锁失效问题**以及**锁分段问题**。这些问题不仅影响系统的稳定性和性能,还可能导致数据不一致。尼恩在实际项目中总结了这些坑,并提供了详细的解决方案,包括使用Lua脚本保证原子性、设置合理的锁过期时间和使用看门狗机制、以及通过锁分段提升性能。这些经验和技巧对面试和实际开发都有很大帮助,值得深入学习和实践。
太惨痛: Redis 分布式锁 5个大坑,又大又深, 如何才能 避开 ?
|
4月前
|
NoSQL Redis
基于Redis的高可用分布式锁——RedLock
这篇文章介绍了基于Redis的高可用分布式锁RedLock的概念、工作流程、获取和释放锁的方法,以及RedLock相比单机锁在高可用性上的优势,同时指出了其在某些特殊场景下的不足,并提到了ZooKeeper作为另一种实现分布式锁的方案。
129 2
基于Redis的高可用分布式锁——RedLock
|
4月前
|
缓存 NoSQL Java
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
这篇文章是关于如何在SpringBoot应用中整合Redis并处理分布式场景下的缓存问题,包括缓存穿透、缓存雪崩和缓存击穿。文章详细讨论了在分布式情况下如何添加分布式锁来解决缓存击穿问题,提供了加锁和解锁的实现过程,并展示了使用JMeter进行压力测试来验证锁机制有效性的方法。
SpringBoot整合Redis、以及缓存穿透、缓存雪崩、缓存击穿的理解分布式情况下如何添加分布式锁 【续篇】
|
2月前
|
缓存 NoSQL Java
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
67 3
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
|
2月前
|
NoSQL Redis 数据库
计数器 分布式锁 redis实现
【10月更文挑战第5天】
51 1
|
2月前
|
NoSQL 算法 关系型数据库
Redis分布式锁
【10月更文挑战第1天】分布式锁用于在多进程环境中保护共享资源,防止并发冲突。通常借助外部系统如Redis或Zookeeper实现。通过`SETNX`命令加锁,并设置过期时间防止死锁。为避免误删他人锁,加锁时附带唯一标识,解锁前验证。面对锁提前过期的问题,可使用守护线程自动续期。在Redis集群中,需考虑主从同步延迟导致的锁丢失问题,Redlock算法可提高锁的可靠性。
83 4