MongoDB资源预订场景并发控制优化方案咨询

嘿，作为MongoDB新手碰到这种大规模资源预订的并发问题太正常了，我来给你拆解下可行的方案和最佳实践，帮你避开集合级锁的瓶颈～

先给你吃颗定心丸：MongoDB默认就是文档级锁！ #

你担心的集合级锁其实是老版本（3.0之前）MMAPv1引擎的问题，现在MongoDB默认用的WiredTiger引擎天生支持文档级锁——也就是说，当你更新某一个资源文档时，只会锁定这单个文档，完全不会影响集合里其他资源的读写操作。这正好解决了你最担心的“一个资源预订锁全集合”的问题，所以你的文档级锁思路完全是正确的，不用怀疑它的效果！

数据模型选择：嵌入还是拆分？ #

你原本想把预订文档嵌入资源文档里，这个方案在预订记录不多的时候很高效，但要考虑长期扩展性：

• 如果每个资源的预订记录不会特别多（比如单资源几百条以内），嵌入模式没问题，查询资源和它的预订记录只需要一次查询，性能很好。
• 如果单资源的预订记录会持续增长到成千上万条，建议把预订拆成单独的集合，用资源ID关联（比如bookings集合里存resourceId字段）。这样可以避免资源文档过大导致的读写性能下降，也方便单独对预订数据做统计、归档操作。

并发控制的具体实现 #

即使有文档级锁，还是需要在业务层做并发控制，避免同一资源被重复预订：

1. 乐观锁（推荐，适合高并发短操作） #

给每个资源文档加一个version字段，每次更新时带上当前版本号，只有版本匹配才会执行更新：

// 先获取资源当前版本
const resource = db.resources.findOne({_id: ObjectId("资源ID")});
// 尝试添加预订并递增版本号
const result = db.resources.updateOne(
  {_id: ObjectId("资源ID"), version: resource.version},
  {
    $push: {bookings: {userId: "用户ID", startTime: ISODate("..."), endTime: ISODate("...")}},
    $inc: {version: 1}
  }
);
// 如果更新结果的matchedCount为0，说明有并发修改，客户端可以重试
if (result.matchedCount === 0) {
  // 重试逻辑
}

这种方式没有锁等待，性能很高，适合大多数高频预订场景。

2. 悲观锁（适合长操作场景） #

如果你的预订流程需要多步操作（比如用户填写信息、支付等，耗时较长），可以给资源加锁定标记：

// 尝试锁定资源，只有未锁定的资源才会被修改
const lockedResource = db.resources.findAndModify({
  query: {_id: ObjectId("资源ID"), isLocked: false, lockExpireAt: {$lt: new Date()}},
  update: {
    $set: {isLocked: true, lockExpireAt: new Date(Date.now() + 30 * 60 * 1000)} // 锁定30分钟
  },
  new: true
});
if (!lockedResource) {
  // 资源已被锁定，提示用户稍后再试
}
// 完成预订后解锁
db.resources.updateOne(
  {_id: ObjectId("资源ID")},
  {$set: {isLocked: false, lockExpireAt: null}}
);

一定要加过期时间，避免因为客户端异常导致资源永远被锁定。

集群扩展：分片提升并行能力 #

当用户和资源量真的达到单实例扛不住的量级时，MongoDB分片集群可以帮你进一步提升扩展性：

• 按资源的某个维度分片（比如资源类别、所属地区），把不同的资源分布到不同的分片服务器上。这样不同分片上的资源预订操作可以完全并行执行，单个分片的压力也会降低。
• 分片后，查询特定资源时，MongoDB会自动路由到对应的分片，不需要你手动处理。

额外提示：事务的使用 #

如果你的预订流程涉及多个文档的修改（比如创建预订记录同时更新用户的积分、资源的库存），MongoDB 4.0+支持多文档事务，可以保证这些操作的原子性。不过要注意，事务会有一定性能开销，只在必要的时候使用就好。

总结一下：先用WiredTiger的文档级锁解决集合锁问题，根据预订量选择合适的数据模型，用乐观锁或悲观锁做业务层并发控制，最后用分片集群应对超大规模的并发需求。这样你的预订系统就能兼顾性能和扩展性啦～

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