Laravel中多用户并发操作钱包数据的问题求助

问题根源分析 #

你的代码存在两个核心问题，导致并发场景下余额计算错误：

1. 锁时机滞后：lockForUpdate()是在插入交易记录之后才获取用户行锁，此时并发请求已经读取了旧的钱包余额（3000美元）并完成了交易记录插入，锁无法阻止前期的脏读。
2. 余额预计算脱离事务：opening_balance和closing_balance是在事务外部预先计算好的，没有基于锁后的实时余额，导致两个并发操作都用旧余额生成交易记录，最终后执行的钱包更新会覆盖前一个操作的结果。

以你提供的场景为例：

• 提现操作先读取3000余额，计算出closing_balance=1000，插入交易记录后加锁更新钱包；
• 充值操作同时读取3000余额，计算出closing_balance=8000，插入交易记录后加锁更新钱包；
• 最终钱包余额被后执行的操作覆盖，出现1000美元的错误结果。

修正后的代码实现 #

DB::transaction(function () use ($amount, $service, $service_type, $user_id, $transaction_id, $metadata, $credit) {
    // 1. 先获取用户行排他锁，阻塞所有并发读写请求
    $user = User::lockForUpdate()->findOrFail($user_id);
    
    // 2. 基于锁后的实时余额计算交易数据
    $opening_balance = $user->wallet;
    // 根据 debit/credit 逻辑计算最终余额：原有余额 - 支出 + 收入
    $closing_balance = $opening_balance - $amount + $credit;
    
    // 3. 插入交易记录（使用实时计算的余额）
    DB::table('transactions')->insert([
        'debit_amount' => $amount,
        'transaction_for' => $service,
        'user_id' => $user_id,
        'trigered_by' => $user_id,
        'credit_amount' => $credit,
        'opening_balance' => $opening_balance,
        'closing_balance' => $closing_balance,
        'service_type' => $service_type,
        'metadata' => $metadata,
        'transaction_id' => $transaction_id,
        'created_at' => now(),
        'updated_at' => now()
    ]);
    
    // 4. 更新用户钱包余额
    $user->update(['wallet' => $closing_balance]);
}, 2);

关键优化点说明 #

• 前置锁机制：将lockForUpdate()放在所有余额读取和计算之前，确保同一时间只有一个操作能处理该用户的钱包数据，彻底避免脏读。
• 实时余额计算：在锁内读取用户当前钱包余额作为交易的opening_balance，再计算closing_balance，保证交易记录和钱包余额的一致性。
• 事务原子性：所有操作（锁用户、计算、插入交易、更新钱包）都在同一个事务内执行，确保任何一步失败都会回滚，避免数据不一致。

额外防护建议 #

• 余额合法性校验：对于提现/转账操作，在锁后添加余额充足校验（如$user->wallet >= $amount），防止并发操作导致余额负数。
• 原子更新替代（可选）：如果不需要生成包含opening_balance和closing_balance的交易记录，可以直接使用Laravel的原子更新方法，无需显式锁：

  // 充值：原子增加余额
  $user->increment('wallet', $credit);
  // 提现：原子减少余额
  $user->decrement('wallet', $amount);
  

内容的提问来源于stack exchange，提问作者Sangam Kumar