PHP乐观锁解决事务并发扣除余额失败

本文针对PHP环境下使用乐观锁和数据库事务进行余额扣除时出现的并发问题，提供了详细的解决方案。文章分析了两种错误代码，指出其缺陷在于乐观锁位置错误和事务管理不当，导致余额扣除失败或数据不一致。错误一将`find()`方法置于事务外，导致乐观锁失效；错误二则将余额更新置于事务外，后续操作失败时数据不一致。最终，文章给出了正确的解决方案：将乐观锁条件判断放入数据库`update`语句中，并将所有操作包含在同一事务内，确保原子性，有效避免并发冲突，提高数据安全性。

PHP乐观锁与数据库事务结合扣除余额：问题分析与解决方案

本文探讨在PHP环境下，使用乐观锁和数据库事务进行余额扣除时，如何避免并发问题导致余额扣除失败或数据不一致的情况。 我们将分析错误代码，并提供正确的解决方案。

问题代码分析及错误原因：

以下代码片段试图通过乐观锁和事务保证并发环境下余额扣除的正确性，但存在缺陷：

错误代码片段一：

public function userbuy()
{
    $user = $this->getuser(); 
    $oldmoney = $user['balance']; 
    $orderoffer = $this->getordermoney($orderid); 
    if($oldmoney < $orderoffer['price']) $this->error('账户余额不足');

    //乐观锁方案 (错误之处)
    $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(); //提交事务 (多余操作)        
    });
}

错误原因：

1. 乐观锁位置错误： find() 方法在事务外部执行。多个并发请求都获取到相同的 $oldmoney 值。 只有第一个请求的 save() 操作成功，后续请求由于 balance 不再等于 $oldmoney 而失败。 乐观锁的条件判断应该在 update 语句中进行。

2. db::commit() 多余： db::transaction() 方法本身会自动提交事务，除非发生异常回滚。手动调用 db::commit() 冗余且可能掩盖错误。

错误代码片段二：

public function userbuy()
{
    // ... (代码同上，省略部分) ...

    //乐观锁方案 (错误之处)
    $newUser->balance = $newMoney;
    $result = $newUser->save();
    if(!$result) $this->error('保存余额失败');

    //开启数据库事务 (错误之处)
    Db::transaction(function () use(){
         //创建订单 code
         //扣除库存 code
         //创建用户余额变动记录 code    
        Db::commit(); //提交事务 (多余操作)         
    });
}

错误原因：

余额更新操作在事务外部执行。如果后续操作（创建订单、扣除库存等）失败，余额已经更新，导致数据不一致。

正确解决方案：

应该将乐观锁的条件判断放在数据库 update 语句中，并将所有需要保证原子性的操作都包含在同一个事务中。

正确代码：

public function userbuy()
{
    $user = $this->getuser();
    $oldmoney = $user['balance'];
    $orderoffer = $this->getordermoney($orderid);
    if ($oldmoney < $orderoffer['price']) $this->error('账户余额不足');

    $newmoney = $oldmoney - $orderoffer['price'];

    // 使用数据库的乐观锁机制 (例如MySQL)
    $affectedRows = smsuser::where('id', $user['id'])
        ->where('balance', $oldmoney)
        ->update(['balance' => $newmoney]);

    if ($affectedRows === 0) {
        $this->error('余额更新失败，可能存在并发冲突'); // 乐观锁失败
        return;
    }

    // 开启事务，包含所有后续操作
    db::transaction(function () use ($orderid, $newmoney, $user) {
        // 创建订单 code
        // 扣除库存 code
        // 创建用户余额变动记录 code  (确保这些操作也包含在事务中)
    });
}

这个解决方案将余额更新和后续操作都放在同一个事务中，并使用数据库提供的乐观锁机制来保证数据一致性。如果任何操作失败，事务会自动回滚，确保数据安全。 避免了手动提交事务，简化了代码并提高了可读性。 如果 update 语句影响的行数为0，则表示乐观锁失败，需要处理并发冲突。 可以使用重试机制或其他策略处理此类情况。 具体的乐观锁实现方式取决于使用的数据库系统。

今天关于《PHP乐观锁解决事务并发扣除余额失败》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！