MongoDB安全事务实现：自动递增字段防竞态条件验证

我正在开发基于Node.js和Mongoose的MongoDB应用，采用事务处理带自动递增position字段的新主题创建逻辑，旨在避免多请求同时递增position引发的竞态条件冲突。请问这段代码能否确保该防护效果？

代码如下：

const createTopic = async (topic: any) => {
  const session = await mongoose.startSession();
  session.startTransaction();

  try {
    // Atomically increment the position and retrieve the last document
    const lastDocument = await Topics.findOneAndUpdate(
      {},
      { $inc: { position: 1 } }, // Increment the highest position by 1
      { sort: { position: -1 }, new: true, session }
    );

    const newPosition = lastDocument ? lastDocument.position : 1;

    const newDocument = new Topics({
      name: topic.name,
      description: topic.description,
      position: newPosition,
    });

    await newDocument.save({ session });
    await session.commitTransaction();
    await session.endSession();

    return { ok: true };
  } catch (error) {
    await session.abortTransaction();
    await session.endSession();

    return { ok: false, error };
  }
};

回答：这段代码无法满足需求，存在逻辑错误和竞态隐患 #

核心问题分析 #

1. position生成逻辑完全错误
   你的代码是对已有主题中position最大的文档执行$inc操作，再将修改后的值作为新主题的position。这会直接导致已有主题与新主题的position重复——比如原本最大position为5，修改后变成6，新主题的position也设为6，完全违背了“每个主题position唯一且递增”的设计目标。

2. 事务无法解决竞态问题
   即便忽略上述逻辑错误，事务也无法阻止并发场景下的异常：

   • 多个并发请求进入事务后，会基于MongoDB的快照隔离读取到相同的“最大position文档”；
   • 虽然findOneAndUpdate是原子操作，但多个请求会依次修改同一条文档的position，导致新主题的position看似递增，但本质是在“篡改”已有主题的position，完全偏离了“新主题自动获取递增position”的初衷。

正确的实现方案 #

要安全生成唯一递增的position，需使用独立计数器集合维护全局序列，而非修改已有文档。示例代码如下：

// 先定义计数器模型
const CounterSchema = new mongoose.Schema({
  _id: { type: String, required: true }, // 计数器标识，如'topicPosition'
  sequence_value: { type: Number, default: 0 }
});

const Counter = mongoose.model('Counter', CounterSchema);

const createTopic = async (topic: any) => {
  const session = await mongoose.startSession();
  session.startTransaction();

  try {
    // 原子递增计数器并获取最新值，不存在则自动创建
    const counter = await Counter.findOneAndUpdate(
      { _id: 'topicPosition' },
      { $inc: { sequence_value: 1 } },
      { new: true, upsert: true, session }
    );

    const newPosition = counter.sequence_value;

    const newDocument = new Topics({
      name: topic.name,
      description: topic.description,
      position: newPosition,
    });

    await newDocument.save({ session });
    await session.commitTransaction();
    await session.endSession();

    return { ok: true };
  } catch (error) {
    await session.abortTransaction();
    await session.endSession();

    return { ok: false, error };
  }
};

方案有效性说明 #

• findOneAndUpdate对计数器的操作是原子性的，MongoDB会保证多个并发请求的递增操作依次执行，不会出现两个请求获取相同sequence_value的情况；
• 事务确保“计数器递增+新主题创建”的原子性，要么全部成功，要么全部回滚，避免数据不一致。

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