NodeJS健身房时段预约并发超员问题及Bull队列选型疑问

一、数据库原子操作（最优方案） #

核心思路是避免"先查询再更新"的分离操作，直接让数据库执行原子性的判断+更新，从根源上消除竞态：

• 若使用关系型数据库（比如MySQL），用单条SQL语句完成判断和更新：

  UPDATE gym_slots 
  SET current_participants = current_participants + 1 
  WHERE slot_id = ? AND current_participants < max_capacity;
  

  执行后检查受影响行数：返回1则预约成功，返回0则时段已满。
• 若使用MongoDB，用findOneAndUpdate实现原子操作：

  const updatedSlot = await GymSlot.findOneAndUpdate(
    { _id: slotId, currentParticipants: { $lt: maxCapacity } },
    { $inc: { currentParticipants: 1 } },
    { new: true }
  );
  if (updatedSlot) {
    // 预约成功逻辑
  } else {
    // 时段已满提示
  }
  

  这种方式依赖数据库本身的并发控制，性能和可靠性都远优于应用层处理。

二、Bull队列的正确用法（可行方案） #

如果你坚持用Bull，要确保所有预约请求串行处理：

• 将每个预约请求封装为队列任务，任务内部执行查询+更新逻辑（因为串行执行，不会出现同时抢占空位的情况）
• 配置队列的concurrency参数为1，确保同一时段的预约任务逐个处理
• 优势：可额外实现重试、失败通知、任务日志等功能；劣势：相比数据库原子操作，多了队列的额外开销，适合需要复杂业务流程的场景

三、应用层分布式锁（谨慎使用） #

用Redis分布式锁（比如redlock库）锁定对应时段，确保同一时间只有一个请求处理预约：

const lock = await redlock.lock(`gym-slot:${slotId}`, 5000); // 锁定5秒
try {
  const slot = await GymSlot.findById(slotId);
  if (slot.currentParticipants < slot.maxCapacity) {
    slot.currentParticipants += 1;
    await slot.save();
    // 预约成功
  } else {
    // 时段已满
  }
} finally {
  await lock.unlock();
}

注意：锁的超时时间需合理设置，超时未释放可能导致死锁，可靠性不如数据库原子操作。

内容的提问来源于stack exchange，提问作者Carlos Saiz Orteu