php中使用乐观锁和事务扣除余额为何只成功扣了1次?
在使用乐观锁扣除余额时,需要将所有涉及的事务性操作置于事务范围内,以保证原子性。在您的第一个代码片段中,存在以下问题:
事务范围错误
事务应涵盖所有数据操作,包含查询用户余额、计算订单价格、判断余额是否充足、修改用户余额、创建订单、扣除库存以及创建用户余额变动记录等步骤。然而,您只将余额操作部分置于事务中,导致事务隔离不完全。
立即学习“PHP免费学习笔记(深入)”;
乐观锁使用错误
真正的乐观锁需要基于数据库的版本号或时间戳进行,以确保在更新数据时不会覆盖其他用户的更改。您的代码中使用了find查询获取用户信息,这会再次读取数据库,破坏了乐观锁的机制。
手动提交事务
db::transaction内部会自动调用提交(commit),无需手动执行。如果需要回滚,只需在代码中抛出异常,事务会自动回滚并继续抛出异常。
在您的第二个代码片段中,将所有操作置于事务中,解决了事务范围错误的问题。但由于省略了find查询,也就丢失了乐观锁的功能。
正确使用乐观锁的代码示例:
public function userbuy() { $user = $this->getUser(); $oldBalance = $user['balance']; $orderOffer = $this->getOrderMoney($orderId); if ($oldBalance < $orderOffer['price']) $this->error('账户余额不足'); // 乐观锁:获取用户余额版本号 $version = SmsUser::where('id', $user['id'])->value('version'); // 开启数据库事务 Db::transaction(function () use ($user, $oldBalance, $orderOffer, $version) { $newUser = SmsUser::where(['id' => $user['id'], 'version' => $version]) ->lockForUpdate() ->find(); if (!$newUser) $this->error('用户不存在或版本号已更改'); $newUser->balance = $oldBalance - $orderOffer['price']; $result = $newUser->save(); if (!$result) $this->error('保存余额失败'); // 创建订单、扣除库存、创建用户余额变动记录等操作 }); }
在这个示例中,我们使用lockforupdate锁定了用户信息,确保在事务执行期间不会被其他请求修改。同时,使用where条件判断版本号是否发生改变,防止并发操作造成数据不一致。