
PHP乐观锁与数据库事务结合扣除余额:深度解析并发更新问题
在PHP开发中,使用乐观锁和数据库事务处理余额扣除操作时,常常面临并发更新的挑战。本文将通过一个案例分析,深入探讨如何避免并发更新导致余额只扣除一次的问题,并提供有效的解决方案。
案例:假设用户同时购买5个单价1元的商品,初始余额为100元。预期结果是余额扣除5元,变为95元。但实际结果可能仅扣除1元,余额变为99元。
代码分析及问题:
我们分析两种常见的错误代码实现方式:
方案一:乐观锁在事务外
此方案尝试在数据库事务中使用乐观锁,但find()操作位于事务之外。多个并发请求可能读取相同的旧余额,导致乐观锁失效,只有一个请求能成功更新余额。
public function userbuy()
{
// ...代码省略...
// 乐观锁方案
$newmoney = $oldmoney - $orderoffer['price'];
$newuser = smsuser::where(['id' => $user['id'],'balance' => $oldmoney])->find();
if(!$newuser) $this->error('用户不存在');
// 开启数据库事务
db::transaction(function () use($newuser,$orderid,$newmoney){
$newuser->balance = $newmoney;
$result = $newuser->save();
if(!$result) $this->error('保存余额失败');
// 创建订单 code
// 扣除库存 code
// 创建用户余额变动记录 code
// db::commit(); // 不需要手动提交
});
}方案二:余额更新在事务外
此方案将余额更新操作移出事务,其他操作仍在事务中。这避免了方案一中的乐观锁失效问题,但如果后续操作(创建订单、扣除库存等)发生异常,余额更新无法回滚,数据一致性无法保证。
public function userbuy()
{
// ...代码省略...
// 乐观锁方案
$newMoney = $oldMoney - $orderOffer['price'];
$newUser = SmsUser::where(['id' => $user['id'],'balance' => $oldMoney])->find();
if(!$newUser) $this->error('用户不存在');
$newUser->balance = $newMoney;
$result = $newUser->save();
if(!$result) $this->error('保存余额失败');
// 开启数据库事务
Db::transaction(function () use(){
// 创建订单 code
// 扣除库存 code
// 创建用户余额变动记录 code
// Db::commit(); // 不需要手动提交
});
}根本原因与正确解决方案:
问题核心在于事务的隔离性和乐观锁的应用方式。 正确的做法是:将所有与余额扣除相关的操作都包含在同一个数据库事务中,并利用数据库提供的乐观锁机制(例如UPDATE ... WHERE ...语句中的条件判断)。 数据库事务的commit()和rollback()操作由数据库系统自动管理,无需手动调用。
通过在UPDATE语句中加入版本号或时间戳等条件,确保只有当余额与读取时的余额一致时,才能成功更新。如果不一致,则表示乐观锁失败,事务会自动回滚。
总而言之,高效利用乐观锁和事务的关键在于:确保所有相关操作都在同一个事务中,并正确使用数据库提供的乐观锁机制,避免手动控制事务提交,让数据库系统自动管理事务的完整性。 这样才能有效地保证数据的一致性和完整性。

