悲观锁通过select ... for update加锁阻塞并发,乐观锁用version或时间戳校验更新时一致性,redis分布式锁解决多服务器互斥,cas工具类封装自动重试机制。

当多个用户同时访问并修改数据库中的同一行数据时,可能出现数据不一致问题。乐观锁与悲观锁是解决并发控制的两种核心机制。以下是这两种锁在PHP中的具体实现方式:
一、悲观锁的PHP实现
悲观锁假设冲突频繁发生,因此在操作数据前就对数据加锁,阻止其他事务并发修改。在MySQL中通常通过SELECT ... FOR UPDATE或LOCK IN SHARE MODE语句实现,需配合事务使用。
1、开启MySQL事务:使用PDO执行beginTransaction()方法启动事务。
2、执行带锁查询:执行SELECT * FROM users WHERE id = 1 FOR UPDATE语句,该语句会锁定id为1的记录直到事务结束。
3、执行业务逻辑:如更新用户余额,执行UPDATE users SET balance = balance - 100 WHERE id = 1。
4、提交或回滚事务:根据业务结果调用commit()或rollback()释放锁。
二、基于版本号的乐观锁实现
乐观锁假设冲突较少,不在数据库层面加锁,而是在更新时校验数据是否被其他事务修改过。典型方式是在表中增加version字段,每次更新时检查当前version是否与读取时一致。
1、读取数据及当前version值:执行SELECT id, name, balance, version FROM users WHERE id = 1。
2、执行业务计算:如判断余额是否充足,确定新余额值。
3、条件更新:执行UPDATE users SET balance = ?, version = version + 1 WHERE id = ? AND version = ?,将原version作为WHERE条件。
4、检查影响行数:使用PDOStatement::rowCount()判断是否返回1;若为0,说明version已变更,本次更新失败,需重试或抛出异常。
三、基于时间戳的乐观锁实现
与版本号机制类似,但使用updated_at等时间戳字段代替version字段进行并发校验,适用于已有时间戳字段且不便于新增字段的表结构。
1、读取数据及updated_at值:SELECT id, name, balance, updated_at FROM users WHERE id = 1。
2、执行业务处理:完成所需的数据变更逻辑。
3、条件更新语句:UPDATE users SET balance = ?, updated_at = NOW() WHERE id = ? AND updated_at = ?。
4、验证更新结果:若PDO返回影响行为0,表示数据已被其他事务修改,当前操作应拒绝提交。
四、使用Redis实现分布式悲观锁
在多服务器部署的PHP应用中,数据库行锁无法跨进程生效,可借助Redis的SETNX命令实现全局互斥锁,确保同一时刻仅一个请求能进入临界区。
1、生成唯一锁键:如"lock:user:1",其中1为用户ID。
2、尝试获取锁:执行Redis::set($key, $value, ['nx', 'ex' => 10]),设置10秒过期防止死锁。
3、判断返回值:若返回TRUE则获得锁,可继续执行数据库操作;若返回FALSE,需等待或立即返回锁冲突提示。
4、操作完成后释放锁:使用Lua脚本原子性删除键,避免误删他人锁。
五、CAS风格的乐观锁封装类
为提升复用性,可封装一个支持自动重试的乐观锁工具类,内部统一处理版本校验、更新失败重试及最大尝试次数限制。
1、定义重试次数上限:如默认3次,避免无限循环。
2、在循环内执行读取-计算-更新流程:每次更新失败后重新SELECT最新数据。
3、每次更新前校验version字段是否匹配:仅当匹配时才执行UPDATE。
4、达到重试上限仍未成功时,终止操作并抛出OptimisticLockException异常。
php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!











