讲师中心 微信公众号
AI工具推荐 视频效率加速

TP8.0 中使用 Redis 实现分布式锁示例【并发控制】

星枫小哥_5741

星枫小哥_5741

发布时间:2026-07-13 20:48:26

|

975人浏览过

|

来源于php中文网

原创

Laravel 8.0(实为ThinkPHP 8.0)中需用Redis原子操作实现分布式锁防超卖,推荐手写LockService或使用think-redis-lock扩展,并必须启用自动续期机制避免锁提前释放。

tp8.0 中使用 redis 实现分布式锁示例【并发控制】

在 Laravel 8.0(TP8.0 是指 ThinkPHP 8.0 的常见误写,实际应为 ThinkPHP 8.0)中实现并发控制时,必须防止多个请求同时修改同一库存或订单状态导致超卖、重复提交等问题。直接用数据库行锁或 PHP 原生 sleep+select 不可靠,需借助 Redis 的原子性操作构建可重入、防误删、带自动续期能力的分布式锁。

手动实现:基于 SET 命令 + Lua 脚本的原子加锁与解锁

这是最轻量、不依赖第三方扩展的方案,适用于已接入 Redis 且对锁粒度有明确控制需求的场景。

第一步:在 config/cache.php 中确认 Redis 连接已启用,并确保 【Redis 服务运行正常且 PHP redis 扩展已加载】,否则后续所有操作会静默失败。

第二步:编写 LockService 类,存放在 app/service/LockService.php:

使用 Redis::set() 的原子参数组合:key、value(客户端唯一标识)、选项数组 ['nx' => true, 'ex' => 30] → 表示“仅当 key 不存在时设置,且过期时间为 30 秒”。这一步替代了旧式 setnx + expire 两步操作,彻底规避死锁风险。

第三步:解锁必须用 Lua 脚本校验 value 再删除,避免 A 线程锁过期后被 B 获取,A 仍执行 del 导致误删 B 的锁。脚本内容为:if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end。调用时传入 lockKey 和当初 set 的唯一 client_id。

第四步:在控制器中使用:

$lock = new \app\service\LockService('order:pay:'.$orderId);
if (!$lock->acquire(5)) { // 尝试获取锁,最多等 5 秒
    throw new \think\Exception('系统繁忙,请稍后再试');
}
try {
    // 执行扣库存、生成订单等核心逻辑
} finally {
    $lock->release(); // 必须放在 finally 中,确保释放
}

使用 think-redis-lock 扩展包快速集成

如果你希望跳过手写 Lua 和异常兜底逻辑,推荐直接引入社区验证过的扩展包,它已内置可重入、自动续期、阻塞等待等能力。

方法一:安装扩展包

Redis Skill - 高性能缓存管理
Redis Skill - 高性能缓存管理

Redis 缓存和数据结构管理技能。通过自然语言操作 Redis,支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。

下载

执行命令:composer require topthink/think-redis-lock,安装完成后无需额外配置,自动读取当前应用的 redis 配置。

方法二:在业务代码中调用

$lock = \think\facade\Cache::lock('goods:stock:'.$goodsId, 30);
if ($lock->get()) {
    try {
        // 扣减库存逻辑
    } finally {
        $lock->release();
    }
} else {
    throw new \think\Exception('操作冲突,请重试');
}

注意:该扩展默认使用 UUID 作为 client_id,且 unlock 时自动校验,不支持跨进程共享锁上下文,【务必不要在协程或 Swoole 长连接中复用同一个 Lock 实例】,每次请求需新建。

高并发下必须开启锁自动续期

当业务逻辑执行时间可能超过锁过期时间(例如支付回调处理耗时 45 秒),必须启用续期机制,否则锁提前释放会导致并发穿透。

第一步:启用心跳续期功能。在 acquire() 后立即启动后台定时器,每 10 秒调用一次 Redis::expire($key, 30),前提是当前 client_id 仍持有该 key —— 这需要先 get 对比再 expire,但 get+expire 非原子,所以必须改用 Lua:

if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('expire', KEYS[1], tonumber(ARGV[2])) else return 0 end

第二步:续期任务需绑定到当前请求生命周期。ThinkPHP 8.0 中可在 middleware 或 controller 构造函数里注册 shutdown 函数清理定时器,避免子进程残留。

第三步:设置合理续期间隔。续期间隔必须小于锁过期时间的一半(如锁设为 30 秒,则续期间隔 ≤12 秒),否则存在窗口期被其他客户端抢占。

热门AI工具

更多
咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

超级简历WonderCV

一款AI办公效率工具,主要用于免费求职简历模版下载制作,应届生职场人必备简历制作神器,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

相关专题

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

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

1953

2023.08.11

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

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

2794

2023.10.07

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

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

4309

2023.11.02

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

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

3815

2023.11.14

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

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

6912

2024.04.02

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

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

623

2024.04.07

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

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

736

2024.04.07

mysql和redis怎么保证双写一致性
mysql和redis怎么保证双写一致性

确保 mysql 和 redis 双写一致性的技术包括:1、事务性更新:同时更新 mysql 和 redis,保证一致性;2、主从复制:mysql 主服务器更改同步到 redis 从服务器;3、基于事件的更新:mysql 记录更改并发送到 redis等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

6562

2024.04.07

LLVM自定义Pass怎么写
LLVM自定义Pass怎么写

本专题聚焦LLVM自定义Pass开发,整理Pass类结构、run()方法、PreservedAnalyses、CMake构建、插件注册、-load-pass-plugin加载和测试用例编写流程。

80

2026.09.30

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

进程与SOCKET
进程与SOCKET

共6课时 | 0.5万人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn