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

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 Tair(兼容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
目录
打赏
0
0
0
0
5
分享
相关文章
【📕分布式锁通关指南 02】基于Redis实现的分布式锁
本文介绍了从单机锁到分布式锁的演变,重点探讨了使用Redis实现分布式锁的方法。分布式锁用于控制分布式系统中多个实例对共享资源的同步访问,需满足互斥性、可重入性、锁超时防死锁和锁释放正确防误删等特性。文章通过具体示例展示了如何利用Redis的`setnx`命令实现加锁,并分析了简化版分布式锁存在的问题,如锁超时和误删。为了解决这些问题,文中提出了设置锁过期时间和在解锁前验证持有锁的线程身份的优化方案。最后指出,尽管当前设计已解决部分问题,但仍存在进一步优化的空间,将在后续章节继续探讨。
406 131
【📕分布式锁通关指南 02】基于Redis实现的分布式锁
|
9天前
|
Springboot使用Redis实现分布式锁
通过这些步骤和示例,您可以系统地了解如何在Spring Boot中使用Redis实现分布式锁,并在实际项目中应用。希望这些内容对您的学习和工作有所帮助。
132 83
【📕分布式锁通关指南 03】通过Lua脚本保证redis操作的原子性
本文介绍了如何通过Lua脚本在Redis中实现分布式锁的原子性操作,避免并发问题。首先讲解了Lua脚本的基本概念及其在Redis中的使用方法,包括通过`eval`指令执行Lua脚本和通过`script load`指令缓存脚本。接着详细展示了如何用Lua脚本实现加锁、解锁及可重入锁的功能,确保同一线程可以多次获取锁而不发生死锁。最后,通过代码示例演示了如何在实际业务中调用这些Lua脚本,确保锁操作的原子性和安全性。
27 6
【📕分布式锁通关指南 03】通过Lua脚本保证redis操作的原子性
为什么分布式一定要有redis?
1、为什么使用redis 分析:博主觉得在项目中使用redis,主要是从两个角度去考虑:性能和并发。当然,redis还具备可以做分布式锁等其他功能,但是如果只是为了分布式锁这些其他功能,完全还有其他中间件(如zookpeer等)代替,并不是非要使用redis。
1382 0
Redis,分布式缓存演化之路
本文介绍了基于Redis的分布式缓存演化,探讨了分布式锁和缓存一致性问题及其解决方案。首先分析了本地缓存和分布式缓存的区别与优劣,接着深入讲解了分布式远程缓存带来的并发、缓存失效(穿透、雪崩、击穿)等问题及应对策略。文章还详细描述了如何使用Redis实现分布式锁,确保高并发场景下的数据一致性和系统稳定性。最后,通过双写模式和失效模式讨论了缓存一致性问题,并提出了多种解决方案,如引入Canal中间件等。希望这些内容能为读者在设计分布式缓存系统时提供有价值的参考。感谢您的阅读!
106 6
Redis,分布式缓存演化之路
解决Redis缓存数据类型丢失问题
解决Redis缓存数据类型丢失问题
192 85
Redis 是一个高性能的键值对存储系统,常用于缓存、消息队列和会话管理等场景。
【10月更文挑战第4天】Redis 是一个高性能的键值对存储系统,常用于缓存、消息队列和会话管理等场景。随着数据增长,有时需要将 Redis 数据导出以进行分析、备份或迁移。本文详细介绍几种导出方法:1)使用 Redis 命令与重定向;2)利用 Redis 的 RDB 和 AOF 持久化功能;3)借助第三方工具如 `redis-dump`。每种方法均附有示例代码,帮助你轻松完成数据导出任务。无论数据量大小,总有一款适合你。
102 6
云端问道21期方案教学-应对高并发,利用云数据库 Tair(兼容 Redis®*)缓存实现极速响应
云端问道21期方案教学-应对高并发,利用云数据库 Tair(兼容 Redis®*)缓存实现极速响应
云端问道21期实操教学-应对高并发,利用云数据库 Tair(兼容 Redis®)缓存实现极速响应
本文介绍了如何通过云端问道21期实操教学,利用云数据库 Tair(兼容 Redis®)缓存实现高并发场景下的极速响应。主要内容分为四部分:方案概览、部署准备、一键部署和完成及清理。方案概览中,展示了如何使用 Redis 提升业务性能,降低响应时间;部署准备介绍了账号注册与充值步骤;一键部署详细讲解了创建 ECS、RDS 和 Redis 实例的过程;最后,通过对比测试验证了 Redis 缓存的有效性,并指导用户清理资源以避免额外费用。
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等