- 当前位置：首页 >系统运维 >深入了解redis分布式锁
深入了解redis分布式锁
发布时间：2025-11-04 23:37:13 来源：技术快报 作者：人工智能
深入理解redis分布式锁
哈喽，深入式锁大家好，分布我是深入式锁指北君。
本篇文件我们来介绍如何Redis实现分布式锁的分布演进过程，以及为什么不能直接用Setnx实现分布式锁。深入式锁
1、分布分布式锁简介分布式锁是深入式锁控制分布式系统不同进程共同访问共享资源的一种锁的实现。如果不同的分布系统或同一个系统的不同主机之间共享了某个临界资源，往往需要互斥来防止彼此干扰，深入式锁以保证一致性。分布
业界流行的深入式锁分布式锁实现，一般有这3种方式：
基于数据库实现的分布分布式锁基于Redis实现的分布式锁基于Zookeeper实现的分布式锁这里主要介绍如何通过 Redis 来实现分布式锁。在介绍 Redis 分布式锁之前，深入式锁我们首先介绍一下实现Redis 分布式锁的分布关键命令。
2、深入式锁setnxsetnx key value
Setnx（SET if Not eXists） 命令在指定的 key 不存在时，为 key 设置指定的值。
设置成功，返回 1 。b2b信息网设置失败，返回 0 。
PS：Redis 官方是不推荐基于 setnx 命令来实现分布式锁的，因为会存在很多问题，
①、单点问题。比如：
客户端A 从master拿到锁lock01master正要把lock01同步(Redis的主从同步通常是异步的）给slave时，突然宕机了，导致lock01没同步给slave主从切换，slave节点被晋级为master节点客户端B到master拿lock01照样能拿到。这样必将导致同一把锁被多人使用。②、锁的高级用法，比如读写锁、可重入锁等等，setnx 都比较难实现。
这里先介绍基于 sentnx 实现的分布式锁，后面会介绍官方推荐的基于 redisson 来实现分布式锁。
3、Redis-分布式锁-阶段1接到上文，查询三级分类数据，如果我们部署了多个商品服务，然后多个线程同时去获取三级分类数据，如果不加分布式锁，IT技术网就会导致，每一个部署的商品服务第一次查询都会走 DB。
复制public Map<String, List<Catelog2Vo>> getCatelogJsonWithRedisLock() throws InterruptedException { //一、获取分布式锁
Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", "111"); if(lock){ // true 表示加锁成功,执行相关业务
Map<String, List<Catelog2Vo>> dataFromDb = getDataFromDb(); stringRedisTemplate.delete("lock"); return dataFromDb; }else{ System.out.println("获取分布式锁失败...等待重试..."); //加锁失败...重试机制
//休眠一百毫秒
try { TimeUnit.MILLISECONDS.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } //自旋的方式
return getCatelogJsonWithRedisLock(); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.
设置锁自动过期
复制public Map<String, List<Catelog2Vo>> getCatelogJsonWithRedisLock() throws InterruptedException { //一、获取分布式锁
Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", "111"); if(lock){ // true 表示加锁成功,执行相关业务
//设置过期时间
stringRedisTemplate.expire("lock",30,TimeUnit.SECONDS); Map<String, List<Catelog2Vo>> dataFromDb = getDataFromDb(); stringRedisTemplate.delete("lock"); return dataFromDb; }else{ System.out.println("获取分布式锁失败...等待重试..."); //加锁失败...重试机制
//休眠一百毫秒
try { TimeUnit.MILLISECONDS.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } //自旋的方式
return getCatelogJsonWithRedisLock(); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.
setnx 命令和过期时间保证原子性。
复制public Map<String, List<Catelog2Vo>> getCatelogJsonWithRedisLock() throws InterruptedException { //一、获取分布式锁
Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", "111",30,TimeUnit.SECONDS); if(lock){ // true 表示加锁成功,执行相关业务
//设置过期时间
//stringRedisTemplate.expire("lock",30,TimeUnit.SECONDS); Map<String, List<Catelog2Vo>> dataFromDb = getDataFromDb(); stringRedisTemplate.delete("lock"); return dataFromDb; }else{ System.out.println("获取分布式锁失败...等待重试..."); //加锁失败...重试机制
//休眠一百毫秒
try { TimeUnit.MILLISECONDS.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } //自旋的方式
return getCatelogJsonWithRedisLock(); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.
保证删除的是自己的锁。
复制public Map<String, List<Catelog2Vo>> getCatelogJsonWithRedisLock() throws InterruptedException { //一、获取分布式锁
String uuid = UUID.randomUUID().toString(); Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", uuid,30,TimeUnit.SECONDS); if(lock){ // true 表示加锁成功,执行相关业务
//设置过期时间
//stringRedisTemplate.expire("lock",30,TimeUnit.SECONDS); Map<String, List<Catelog2Vo>> dataFromDb = getDataFromDb(); String lockValue = stringRedisTemplate.opsForValue().get("lock"); if(uuid.equals(lockValue)){ stringRedisTemplate.delete("lock"); } return dataFromDb; }else{ System.out.println("获取分布式锁失败...等待重试..."); //加锁失败...重试机制
//休眠一百毫秒
try { TimeUnit.MILLISECONDS.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } //自旋的方式
return getCatelogJsonWithRedisLock(); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.
通过Lua脚本保证删除锁和判断锁两个操作原子性
复制public Map<String, List<Catelog2Vo>> getCatelogJsonWithRedisLock(){ //一、获取分布式锁
String uuid = UUID.randomUUID().toString(); Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", uuid,30,TimeUnit.SECONDS); if (lock) { System.out.println("获取分布式锁成功..."); Map<String, List<Catelog2Vo>> dataFromDb = null; try { //加锁成功...执行业务
dataFromDb = getDataFromDb(); } finally { String script = "if redis.call(get, KEYS[1]) == ARGV[1] then return redis.call(del, KEYS[1]) else return 0 end"; //删除锁
stringRedisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class), Arrays.asList("lock"), uuid); } //先去redis查询下保证当前的锁是自己的
//获取值对比，对比成功删除=原子性 lua脚本解锁
// String lockValue = stringRedisTemplate.opsForValue().get("lock"); // if (uuid.equals(lockValue)) { // //删除我自己的锁
// stringRedisTemplate.delete("lock"); // } return dataFromDb; }else{ System.out.println("获取分布式锁失败...等待重试..."); //加锁失败...重试机制
//休眠一百毫秒
try { TimeUnit.MILLISECONDS.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } //自旋的方式
return getCatelogJsonWithRedisLock(); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.这也是分布式锁的最终模式，需要保证两个点：加锁【设置锁+过期时间】和删除锁【判断+删除】原子性。
服务器托管- 给计算机装双系统的完全教程（轻松搭建双系统，满足不同需求）
- 飞利浦RQ1250电动剃须刀的品质与性能评测（让你的剃须体验焕然一新的全新选择）
- 探索4K手机的画质和性能表现如何（了解4K手机的关键特点及市场前景）
- 斐讯FWR604H的功能与性能分析（一款值得购买的高性能路由器）
- 电脑深度待机唤醒教程（实现高效省电的电脑待机状态）
- 小创客（培养创新思维，成就未来领袖）
- 从笔记本苹果系统到Win7系统（一步步教你如何将笔记本从苹果系统切换到Win7系统）
- 百度云洗照片功能解析（便捷高效，百度云洗照片为您打造清晰美丽的图片）
- 免费改照片大小KB的软件推荐（简单易用的工具帮助您快速调整照片大小）
- 麦博TMN-1U（功能强大、稳定可靠，满足多种网络需求）
- 微星450主板装机教程（全面解析微星450主板的安装和配置）
- Word批注模式的关闭与使用技巧（轻松掌握Word批注模式的开关方法，提高文档编辑效率）
- 探索以tcluhd为主题的全新世界（解析tcluhd的卓越品质与前沿技术）
- 探究以利勃登音响的品质和性能（一流的音质和出色的技术为您提供绝佳的听觉体验）
- 重装电脑脚本错误的解决方法（快速修复电脑重装脚本错误的技巧）
- 探究AMDFX6120的性能特点（一款高性能处理器的综合评价）
- 《高一洋——一个充满活力的青年》（拥有坚韧、激情与才华的高一洋）
- 使用XP刷写Win10双系统教程（详细步骤和关键技巧，帮助您完成XP刷写Win10双系统）
- 教你简易转换安卓手机m4a音频为mp3格式（一键操作，高效转换，享受更广泛的音频播放体验）
- 高配i7笔记本的性能与优势（探索高配i7笔记本的超强表现与卓越特点）
随便看看
香港云服务器IT技术网源码库源码下载企商汇益华科技服务器租用IT资讯网亿华云亿华科技码上建站亿华云益华科技益强智囊团汇智坊亿华云计算益强前沿资讯极客编程全栈开发益强IT技术网云智核思维库码力社益强编程舍运维纵横多维IT资讯益强编程堂创站工坊亿华智造益华科技IT资讯网亿华互联智能时代编程之道益强科技益强科技益强资讯优选极客码头亿华智慧云
- Copyright © 2025 Powered by 深入了解redis分布式锁,技术快报 滇ICP备2023006006号-46sitemap