当前位置: 首页 > news >正文

Redis 分布式锁原理与实战-学习篇

在微服务、高并发环境中,我们常常需要对共享资源进行加锁控制。分布式锁正是为了解决多个节点竞争同一资源的问题而生。本文将详细介绍 Redis 实现分布式锁的原理、注意事项及 Java 实战代码。

 一、为什么需要分布式锁?

在单体应用中,我们可以使用 synchronizedReentrantLock 解决并发问题,但在分布式系统中,不同服务实例部署在多台服务器上,JVM 层面的锁无法跨节点同步,这时候就需要一个跨进程、跨机器的锁机制,即:分布式锁

二、Redis 为什么适合作为分布式锁?

Redis 本身是单线程 + 内存型数据库,具备以下特点:

  • 操作快(RT < 1ms)

  • 命令原子性强

  • 支持过期时间

  • 可部署高可用结构(哨兵、集群)

所以,用 Redis 来实现分布式锁成为主流做法之一。

三、加锁的核心命令

使用 SET key value NX PX 命令:

SET lock:order:123 abc123 NX PX 30000
  • NX:仅当 key 不存在时设置(确保加锁原子性)

  • PX:设置过期时间(防止死锁)

  • abc123:一般是 UUID,标识当前线程持有锁

返回值

  • "OK" 表示加锁成功

  • nil 表示锁已被他人持有

四、释放锁为何必须用 Lua 脚本?

❌ 错误做法(非原子):

if (jedis.get(key).equals(value)) {jedis.del(key);
}

在高并发环境中,可能在 get 和 del 之间锁就过期了,导致误删了其他线程/服务设置的锁!

✅ 正确做法(Lua 脚本保证原子):

if redis.call('get', KEYS[1]) == ARGV[1] thenreturn redis.call('del', KEYS[1])
elsereturn 0
end

使用 Redis 的 EVAL 命令将 Lua 脚本执行为一个原子操作。

 五、Java 实战代码

加锁实现:

String lockKey = "lock:order:123";
String uuid = UUID.randomUUID().toString();
String result = jedis.set(lockKey, uuid, SetParams.setParams().nx().px(30000));
if ("OK".equals(result)) {// 加锁成功
}

解锁实现(Lua 脚本):

String lua ="if redis.call('get', KEYS[1]) == ARGV[1] then " +"   return redis.call('del', KEYS[1]) " +"else " +"   return 0 " +"end";jedis.eval(lua, Collections.singletonList(lockKey), Collections.singletonList(uuid));

 六、存在的问题与优化建议

问题建议解决方案
锁过期导致误删他人锁使用 UUID + Lua 脚本安全释放
锁未过期业务超时(死锁)使用合理的 PX 设置过期时间
锁意外失效(宕机、GC)使用 Redisson 支持自动续期
不可重入自实现线程绑定锁或使用 Redisson
主从延迟导致锁丢失(Redis 单点)推荐 Redis Sentinel 或 Cluster 部署

 七、推荐:使用 Redisson 简化实现

Redisson 是基于 Redis 的 Java 客户端,支持:

  • 可重入锁

  • 自动续期

  • 公平锁、读写锁

  • 分布式 CountDownLatch

只需一行代码即可加锁:

RLock lock = redisson.getLock("myLock");
lock.lock();
try {// 执行业务逻辑
} finally {lock.unlock();
}

八、总结

Redis 分布式锁是一种高效、实用的并发控制工具,在保证性能的前提下,为微服务系统提供了可靠的锁机制。生产环境中推荐使用 Lua 脚本 + UUID + 过期时间组合,同时考虑使用 Redisson 简化开发与容错处理。

http://www.xdnf.cn/news/1067671.html

相关文章:

  • 【计算机网络】期末复习
  • 轻量化实物建模革命:WebGL如何实现复杂模型的高效加载与交互
  • 14.OCR字符识别
  • 同济大学多模态感知具身导航全面综述
  • 10-Python模块详解
  • Netty内存池核心PoolArena源码解析
  • 机器学习×第十四卷:集成学习中篇——她从每次错误中修正自己
  • 基于目标驱动的分布式敏捷开发
  • 闲庭信步使用SV搭建图像测试平台:第九课——初步使用类
  • 浅谈开源在线客服系统与 APP 集成的技术方案与优劣势
  • 基于单片机的语音控制设计(论文)
  • 黑马Day01-03集开始
  • Springboot项目中使用手机号短信验证码注册登录实现
  • 北京及其周边理工科大学高考招生情况
  • 前端登录状态管理:主流方案对比与安全实践指南
  • Android系统常见有线网卡丢包问题的调试排查方案
  • 【Linux网络编程】多路转接I/O(一)select,poll
  • ci | cd
  • mapbox基础,导出地图
  • Java+GcExcel,生成自定义工作表
  • Rust 项目实战:多线程 Web 服务器
  • 报错:macOS 安装 sentencepiece
  • CentOS 7 通过YUM安装MySQL 8.0完整指南
  • 专题:2025大模型2.0:GPT到DeepSeek技术演进与产业落地报告|附200+份报告PDF汇总下载
  • 云原生周刊:Argo CD v3.1 正式发布
  • MySQL优化:使用 LIMIT 进行分页查询时,偏移量过大造成查询性能降低问题分析
  • AS32A601与ASM1042芯片在电力系统自动化监控中的应用效能分析
  • 基于PostgreSQL的百度或高德等POI多层级分类的数据库设计
  • Towards Generalizable Diabetic Retinopathy Grading in Unseen Domains
  • 【ARM 嵌入式 编译系列 7.5 -- GCC 打印链接脚本各段使用信息】