MongoDB同字段并发乱序更新：字段级时间戳/版本支持咨询

MongoDB本身没有原生的字段级版本/时间戳自动维护功能，但可以通过自定义字段的方式实现你需要的字段级时间戳控制，这是分布式系统中处理乱序更新冲突的常见问题。

核心方案 #

给每个需要做并发保护的字段添加对应的时间戳字段，比如title对应title_ts，desc对应desc_ts。每次更新请求携带微服务1接收请求时生成的时间戳，更新时通过条件判断：仅当传入的时间戳大于文档中该字段当前的时间戳时，才执行更新操作；否则更新不生效，以此拒绝旧版本的乱序请求。

修改后的文档Schema示例 #

{
  _id: ObjectId("唯一文档ID"), // 对应你的unique_doc_id
  title: "title2",
  title_ts: 1620000001000, // T2时刻的毫秒级时间戳
  desc: "desc",
  desc_ts: 1620000000000,
  listField: ["listElement1", "listElement2"],
  listField_ts: 1620000000000,
  mapField: {someKey: "someValue"},
  mapField_ts: 1620000000000
}

更新操作代码示例（Node.js驱动） #

假设T2时刻的title2更新已完成，此时处理T1时刻的title1更新请求（携带时间戳1620000000000）：

const { MongoClient, ObjectId } = require('mongodb');

async function updateTitle(docId, newTitle, requestTimestamp) {
  const client = await MongoClient.connect('mongodb://localhost:27017');
  const db = client.db('yourDatabase');
  const collection = db.collection('yourCollection');

  const updateResult = await collection.updateOne(
    {
      _id: ObjectId(docId),
      title_ts: { $lt: requestTimestamp } // 仅当前时间戳小于请求时间戳时执行更新
    },
    {
      $set: {
        title: newTitle,
        title_ts: requestTimestamp
      }
    }
  );

  await client.close();

  if (updateResult.matchedCount === 0) {
    // 没有匹配到文档，说明当前字段的时间戳已大于请求时间戳，更新被拒绝
    return { success: false, message: "旧版本更新请求已被拒绝" };
  }
  return { success: true, message: "更新成功" };
}

// 调用示例：T1时刻的请求，时间戳小于数据库中已有的title_ts
updateTitle("目标文档ID", "title1", 1620000000000)
  .then(res => console.log(res))
  .catch(err => console.error(err));

注意事项 #

• 时间戳建议使用微服务1接收请求时的服务器时间，避免客户端本地时间不一致导致的时序错误。
• 对于数组、嵌套对象等复杂字段，同样可以添加对应的时间戳字段，更新逻辑与普通字段一致。
• 这种实现属于乐观锁的一种，无需占用数据库锁资源，适合高并发场景下的乱序更新处理。

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