如何解决并发请求下用户余额超扣的数据库问题？

你的代码存在几个关键问题，导致并发场景下余额超扣：

1. 参数位置错误，锁和事务未生效 #

• Balance.decrement的参数格式错误：decrement的第二个参数是配置对象，你把{lock:true, transaction: t}放在了第三个参数，这部分配置会被忽略，导致扣减操作没在事务内执行，也没加锁。
• findOne的锁配置不规范：Sequelize中lock需要明确指定锁类型（比如更新锁），仅传true可能不符合预期。

2. 查询-判断-扣减的非原子性 #

即使锁生效，先查询余额再判断再扣减的逻辑，在并发场景下还是可能出现问题（虽然行锁能缓解，但不如原子操作可靠）。

修复方案：使用原子操作+正确的事务配置 #

直接将余额判断和扣减合并为一个数据库原子操作，同时确保事务和锁正确配置，这样数据库会帮你保证并发安全：

// 假设你使用的是Sequelize
const { Op } = require('sequelize');

try {
  // 启动事务
  const t = await sequelize.transaction();

  // 原子操作：仅当余额 >= 要扣减的金额时，才执行扣减
  const result = await Balance.decrement('balance', {
    by: getAmount,
    where: {
      userId: getUser.id,
      balance: { [Op.gte]: getAmount } // 关键：添加余额充足的条件
    },
    transaction: t,
    lock: t.LOCK.UPDATE // 明确指定更新锁
  });

  // 检查受影响的行数：如果为0，说明余额不足
  if (result[0][1] === 0) {
    await t.rollback();
    res.status(403).json({ message: "Insufficient balance" });
    return;
  }

  // 事务提交
  await t.commit();
  res.status(200).json({ message: "Balance deducted successfully" });
} catch (error) {
  // 异常时回滚事务
  await t?.rollback();
  res.status(500).json({ message: "Server error" });
}

为什么这个方案有效？ #

• 原子性：decrement带条件的操作是数据库层面的原子操作，不会被其他并发请求打断，确保只有余额足够时才会扣减。
• 正确的事务和锁：事务包裹整个操作，更新锁保证其他请求必须等待当前事务完成后才能操作该用户的余额记录。
• 结果判断：通过受影响行数判断是否扣减成功，避免了先查询再判断的中间空隙。

补充：原代码的其他修复点 #

如果你坚持要保留查询-判断-扣减的逻辑，至少要修正参数位置和锁配置：

try {
  const t = await sequelize.transaction();
  
  // 修正findOne的锁配置，放在options里，指定锁类型
  const getUserBalance = await Balance.findOne({
    where: { userId: getUser.id },
    transaction: t,
    lock: t.LOCK.UPDATE
  });

  if (!getUserBalance || getUserBalance.balance < getAmount) {
    await t.rollback();
    res.status(403).json({ message: "Insufficient balance" });
    return;
  }

  // 修正decrement的参数，把事务和锁放在第二个配置对象里
  await Balance.decrement('balance', {
    by: getAmount,
    where: { userId: getUser.id },
    transaction: t,
    lock: t.LOCK.UPDATE
  });

  await t.commit();
  res.status(200).json({ message: "Success" });
} catch (error) {
  await t?.rollback();
  res.status(500).json({ message: "Error" });
}

但这种方式还是不如原子操作可靠，因为查询和扣减之间理论上还是存在极小的风险（虽然行锁会阻止其他请求，但原子操作是数据库原生支持的，更稳妥）。

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