0

0

java后端开发怎么用Redis实现分布式锁?

月夜之吻

月夜之吻

发布时间:2025-11-21 11:53:42

|

562人浏览过

|

来源于php中文网

原创

使用redis实现分布式锁需通过set命令的nx和px选项保证原子性加锁,用lua脚本安全释放锁,防止死锁与误删;为支持可重入和避免超时问题,可结合threadlocal与看门狗机制;生产环境推荐使用redisson框架,其提供自动续期、可重入、异常处理等完整特性,比手动实现更可靠。

java后端开发怎么用redis实现分布式锁?

在Java后端开发中,使用Redis实现分布式锁主要是为了在多节点环境下保证共享资源的线程安全。最常见的方式是利用Redis的SET命令配合NX(不存在时设置)和PX(毫秒级过期时间)选项来实现原子性的加锁操作。

1. 基于SET命令的简单分布式锁

Redis 2.6.12以后,SET命令支持多个参数组合,可以原子性地完成“判断key是否存在 + 设置值 + 设置过期时间”的操作。

示例代码:

public class RedisDistributedLock {
    private static final String LOCK_SUCCESS = "OK";
    private static final String SET_IF_NOT_EXIST = "NX";
    private static final String SET_WITH_EXPIRE_TIME = "PX";

    private Jedis jedis;
    private String lockKey;
    private String requestId;
    private int expireTime;

    public RedisDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {
        this.jedis = jedis;
        this.lockKey = lockKey;
        this.requestId = requestId;
        this.expireTime = expireTime;
    }

    public boolean tryLock() {
        String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);
        return LOCK_SUCCESS.equals(result);
    }
}

说明:

立即学习Java免费学习笔记(深入)”;

  • lockKey 是锁的唯一标识,比如 "lock:order:1001"
  • requestId 通常用UUID,用来标识哪个客户端持有的锁
  • 设置过期时间防止死锁(如程序崩溃未释放)

2. 正确释放锁:Lua脚本保证原子性

释放锁时必须确保只有自己持有的锁才能被释放,避免误删。使用Lua脚本可以保证“读取value-判断-删除”操作的原子性。

public boolean releaseLock() {
    String script = "if redis.call('get', KEYS[1]) == ARGV[1] then " +
                    "return redis.call('del', KEYS[1]) " +
                    "else " +
                    "return 0 " +
                    "end";
    Object result = jedis.eval(script, List.of(lockKey), List.of(requestId));
    return "1".equals(result.toString());
}

关键点:

Mall4j商城系统
Mall4j商城系统

Mall4j是一个基于spring boot、spring oauth2.0、mybatis、redis的轻量级、前后端分离、防范xss攻击、拥有分布式锁、为生产环境多实例完全准备、数据库为b2b2c设计、拥有完整sku和下单流程的java开源商城。

下载
  • 通过比较requestId判断是否为锁持有者
  • Lua脚本在Redis中是原子执行的,不会出现并发问题

3. 可重入性和超时处理

如果需要支持可重入(同一个线程多次获取同一把锁),可以在value中记录线程信息和重入次数,并结合ThreadLocal管理。

关于锁超时:

  • 业务执行时间应远小于锁过期时间
  • 可引入“看门狗”机制(如Redisson中的Watchdog)自动续期
  • 避免锁在业务未完成时过期导致并发问题

4. 推荐使用Redisson框架

手写分布式锁容易出错,生产环境建议使用成熟的开源库,如Redisson

使用示例:

Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);

RLock lock = redisson.getLock("myLock");
try {
    // 尝试加锁,最多等待10秒,上锁后30秒自动解锁
    if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {
        // 执行业务逻辑
    }
} finally {
    lock.unlock();
}

Redisson优势:

  • 自动续期(watchdog机制)
  • 支持可重入、公平锁、读写锁等
  • 封装了网络重连、异常处理等细节

基本上就这些。自己实现要特别注意原子性和异常场景,直接用Redisson更稳妥。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

404

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

251

2023.10.07

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

764

2023.08.10

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1005

2023.11.02

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

671

2023.11.14

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

501

2024.04.02

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

413

2024.04.07

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

408

2024.04.07

Go高并发任务调度与Goroutine池化实践
Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开,系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示,帮助开发者构建稳定高效的 Go 并发任务处理系统,提高系统在高负载环境下的处理能力与稳定性。

4

2026.03.10

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

相关下载

更多

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 4.3万人学习

C# 教程
C# 教程

共94课时 | 11.1万人学习

Java 教程
Java 教程

共578课时 | 80.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号