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

PHP Webman处理并发资源竞争_Webman乐观锁与悲观锁应用【经验】

梦萱吖_1661

梦萱吖_1661

发布时间:2026-05-26 21:29:36

|

236人浏览过

|

来源于php中文网

原创

Webman中需手动实现悲观锁或乐观锁:悲观锁须关闭PDO自动提交、显式事务包裹SELECT FOR UPDATE并确保索引命中;乐观锁必须单条SQL校验version并检查rowCount(),Redis分布式锁适用于多Worker场景。

php webman处理并发资源竞争_webman乐观锁与悲观锁应用【经验】

Webman 中处理并发资源竞争,不能直接套用 Laravel 的 lockForUpdate() 或 Eloquent 乐观锁机制——它没有内置的模型锁方法,也不自动管理事务生命周期。必须手动控制 PDO 事务、SQL 锁语句和版本校验逻辑。

Webman 怎么用 SELECT FOR UPDATE 实现悲观锁

Webman 基于 Swoole,PDO 默认是长连接且自动提交开启(PDO::ATTR_AUTOCOMMIT => true),这会导致 SELECT ... FOR UPDATE 立即释放锁,完全失效。

  • 必须显式关闭自动提交:$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, false)
  • 整个“查-算-改”流程必须包裹在 $pdo->beginTransaction() 和 $pdo->commit() 之间
  • WHERE 条件必须命中索引,否则可能升级为表锁或间隙锁;例如 WHERE id = ? 要求 id 是主键或有索引
  • 执行 SELECT ... FOR UPDATE 后,若其他请求同时尝试相同语句,会阻塞直到前一个事务结束;超时由 MySQL 的 innodb_lock_wait_timeout 控制(默认 50 秒)
  • 避免死锁:所有服务端对同一组记录加锁时,必须保持一致的查询顺序(如总是先锁 user_id 小的,再锁大的)

示例片段:

$pdo = Db::getPdo();
$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, false);
try {
    $pdo->beginTransaction();
    $stmt = $pdo->prepare("SELECT balance, version FROM users WHERE id = ? FOR UPDATE");
    $stmt->execute([$userId]);
    $row = $stmt->fetch(PDO::FETCH_ASSOC);
<pre class="brush:php;toolbar:false;">if ($row['balance'] < $amount) {
    throw new Exception('余额不足');
}

$stmt = $pdo->prepare("UPDATE users SET balance = balance - ? WHERE id = ?");
$stmt->execute([$amount, $userId]);

$pdo->commit();

} catch (Exception $e) { $pdo->rollback(); throw $e; }

Webman 手动实现乐观锁的正确姿势

乐观锁在 Webman 中更轻量,但极易因“读-改-写”拆成两步而失效——比如先 $user->version++ 再 $user->save(),两个并发请求会读到相同 version,都写入 version + 1,导致丢失一次更新。

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

btpanel phpsite 宝塔面板PHP网站
btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理:站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载
  • 必须把版本校验和更新压进**单条 SQL**:UPDATE table SET col = ?, version = version + 1 WHERE id = ? AND version = ?
  • 严格检查 $stmt->rowCount():返回 0 表示更新失败(别人已抢先修改),此时应重试或返回错误,不能忽略
  • 不要依赖 ORM 自动填充 version 字段;Webman 无 Eloquent,需自己拼 SQL 或封装通用 updateWithVersion() 方法
  • 时间戳字段(如 updated_at)可替代 version,但要注意 MySQL 的 NOW() 精度(秒级)可能引发误判,高并发下建议用微秒或自增整数版 version

关键判断逻辑:

$stmt = $pdo->prepare("UPDATE users SET balance = balance - ?, version = version + 1 WHERE id = ? AND version = ?");
$stmt->execute([$amount, $userId, $expectedVersion]);
if ($stmt->rowCount() === 0) {
    // 并发冲突:数据已被他人修改
    throw new OptimisticLockException('version mismatch');
}

Webman 里 sharedLock() 和 lockForUpdate() 没有对应方法

Webman 的 Db 组件不提供 sharedLock() 或 lockForUpdate() 这类链式调用。所谓“共享锁”在 MySQL 中是 SELECT ... LOCK IN SHARE MODE,但它**不防丢失更新**——两个事务都能读到同一行并各自更新,后提交者会覆盖前者。这不是业务需要的并发控制。

  • 真正要防覆盖写,只能用 SELECT ... FOR UPDATE(排他锁)或乐观锁
  • 别试图用 LOCK IN SHARE MODE 替代,它只适合“读完就走、不改数据”的场景,比如生成报表前确保数据不被删除
  • 如果真要用共享锁,得手写 SQL:$pdo->query("SELECT * FROM users WHERE id = 1 LOCK IN SHARE MODE"),但仍需事务包裹,且意义有限

Redis 分布式锁是 Webman 更现实的选择

Webman 常部署多 Worker 进程,甚至多机器,MySQL 行锁仅限单实例内生效。跨进程/跨机器抢库存、发券等场景,必须用 Redis。

  • 用 SET key value NX PX 10000 实现带过期的原子加锁,value 必须唯一(如 uniqid('', true)),防止误删别人锁
  • 解锁必须用 Lua 脚本保证原子性:if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end
  • Webman 可用 redis 扩展直连,或封装成 RedisLock 类,注意设置合理超时(一般 10–30 秒),避免死锁
  • 不要用 sleep 轮询等锁,Swoole 下会阻塞整个协程;应结合 retry + 指数退避

复杂点在于:Redis 锁只是互斥入口,后续仍要配合数据库乐观锁或幂等设计,否则锁住后 DB 更新失败,状态就乱了。

相关文章

PHP速学教程(入门到精通)
PHP速学教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

DeepSeek

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

UpDream
UpDream Hot

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

WorkBuddy

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

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

豆包大模型

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

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

10664

2023.09.01

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

6241

2023.10.11

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

2135

2023.10.11

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

3948

2023.10.23

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

4654

2023.10.23

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

3651

2023.11.03

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

5217

2023.11.09

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4082

2023.11.13

剧云AI短剧创作教程合集
剧云AI短剧创作教程合集

本专题聚焦剧云AI短剧创作,讲解从短剧灵感、梗概、全局大纲到分集、分场和正文的完整流程及节奏设计方法。

0

2026.10.14

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Webman和FastAPI的性能对比
Webman和FastAPI的性能对比

共0课时 | 315人学习

Webman中文手册
Webman中文手册

共0课时 | 0人学习

webman初步使用及后台搭建
webman初步使用及后台搭建

共15课时 | 2.7万人学习

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

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