【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
目录
相关文章
|
1月前
|
存储 NoSQL Java
使用lock4j-redis-template-spring-boot-starter实现redis分布式锁
通过使用 `lock4j-redis-template-spring-boot-starter`,我们可以轻松实现 Redis 分布式锁,从而解决分布式系统中多个实例并发访问共享资源的问题。合理配置和使用分布式锁,可以有效提高系统的稳定性和数据的一致性。希望本文对你在实际项目中使用 Redis 分布式锁有所帮助。
121 5
|
2月前
|
NoSQL Java 数据处理
基于Redis海量数据场景分布式ID架构实践
【11月更文挑战第30天】在现代分布式系统中,生成全局唯一的ID是一个常见且重要的需求。在微服务架构中,各个服务可能需要生成唯一标识符,如用户ID、订单ID等。传统的自增ID已经无法满足在集群环境下保持唯一性的要求,而分布式ID解决方案能够确保即使在多个实例间也能生成全局唯一的标识符。本文将深入探讨如何利用Redis实现分布式ID生成,并通过Java语言展示多个示例,同时分析每个实践方案的优缺点。
76 8
|
2月前
|
机器学习/深度学习 分布式计算 算法
【大数据分析&机器学习】分布式机器学习
本文主要介绍分布式机器学习基础知识,并介绍主流的分布式机器学习框架,结合实例介绍一些机器学习算法。
267 5
|
2月前
|
NoSQL Redis
Redis分布式锁如何实现 ?
Redis分布式锁通过SETNX指令实现,确保仅在键不存在时设置值。此机制用于控制多个线程对共享资源的访问,避免并发冲突。然而,实际应用中需解决死锁、锁超时、归一化、可重入及阻塞等问题,以确保系统的稳定性和可靠性。解决方案包括设置锁超时、引入Watch Dog机制、使用ThreadLocal绑定加解锁操作、实现计数器支持可重入锁以及采用自旋锁思想处理阻塞请求。
64 16
|
2月前
|
缓存 NoSQL PHP
Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出
本文深入探讨了Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出。文章还介绍了Redis在页面缓存、数据缓存和会话缓存等应用场景中的使用,并强调了缓存数据一致性、过期时间设置、容量控制和安全问题的重要性。
47 5
|
20天前
|
存储 缓存 NoSQL
解决Redis缓存数据类型丢失问题
解决Redis缓存数据类型丢失问题
164 85
|
3月前
|
消息中间件 缓存 NoSQL
Redis 是一个高性能的键值对存储系统,常用于缓存、消息队列和会话管理等场景。
【10月更文挑战第4天】Redis 是一个高性能的键值对存储系统,常用于缓存、消息队列和会话管理等场景。随着数据增长,有时需要将 Redis 数据导出以进行分析、备份或迁移。本文详细介绍几种导出方法:1)使用 Redis 命令与重定向;2)利用 Redis 的 RDB 和 AOF 持久化功能;3)借助第三方工具如 `redis-dump`。每种方法均附有示例代码,帮助你轻松完成数据导出任务。无论数据量大小,总有一款适合你。
87 6
|
17天前
|
缓存 监控 NoSQL
Redis经典问题:缓存穿透
本文详细探讨了分布式系统和缓存应用中的经典问题——缓存穿透。缓存穿透是指用户请求的数据在缓存和数据库中都不存在,导致大量请求直接落到数据库上,可能引发数据库崩溃或性能下降。文章介绍了几种有效的解决方案,包括接口层增加校验、缓存空值、使用布隆过滤器、优化数据库查询以及加强监控报警机制。通过这些方法,可以有效缓解缓存穿透对系统的影响,提升系统的稳定性和性能。
|
2月前
|
缓存 NoSQL 关系型数据库
大厂面试高频:如何解决Redis缓存雪崩、缓存穿透、缓存并发等5大难题
本文详解缓存雪崩、缓存穿透、缓存并发及缓存预热等问题,提供高可用解决方案,帮助你在大厂面试和实际工作中应对这些常见并发场景。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
大厂面试高频:如何解决Redis缓存雪崩、缓存穿透、缓存并发等5大难题
|
2月前
|
存储 缓存 NoSQL
【赵渝强老师】基于Redis的旁路缓存架构
本文介绍了引入缓存后的系统架构,通过缓存可以提升访问性能、降低网络拥堵、减轻服务负载和增强可扩展性。文中提供了相关图片和视频讲解,并讨论了数据库读写分离、分库分表等方法来减轻数据库压力。同时,文章也指出了缓存可能带来的复杂度增加、成本提高和数据一致性问题。
【赵渝强老师】基于Redis的旁路缓存架构
下一篇
开通oss服务