NextJS中MongoDB并发更新同一文档仅一个生效的解决咨询

一、解决并发更新丢失问题 #

你当前的问题核心是用$set直接覆盖整个postComments数组，并发场景下两个请求会同时读取旧数组、各自添加评论后再覆盖回去，导致后提交的更新会覆盖先提交的，出现丢失更新的情况。MongoDB的原子操作可以直接解决这个问题，不需要手动做请求队列——改用数组原子更新操作，让MongoDB在服务器端保证每个修改的原子性。

修改updateOne的操作符，把$set换成$push（用于添加单个评论）或$addToSet（避免重复评论）：

export async function addComment(reqBody) {
  // ... 连接部分后续调整
  result = await db
    .collection("posts")
    .updateOne(
      { _id: new ObjectID(reqBody.ID) },
      { $push: { postComments: reqBody.newComment } } // 仅推送新添加的单条评论
    );
}

注意：需要调整前端传入的reqBody，不再传递整个comments数组，只传新增的单条评论内容（比如reqBody.newComment）。这样每个请求只会原子性地往数组末尾添加一条评论，无论多少并发请求，所有评论都会被保留。

二、解决连接数过多问题 #

每次请求都创建新的MongoClient并调用connect()，会导致大量短连接占用MongoDB的连接数配额。MongoClient本身内置连接池，应该全局复用同一个客户端实例，而不是每次请求都创建新实例。

在NextJS中可以通过全局变量实现单例客户端：

const MongoClient = require("mongodb").MongoClient;
const url = "serverurl";
const ObjectID = require("mongodb").ObjectId;

// 全局保存MongoClient实例，仅初始化一次
let mongoClient;

// 获取复用的客户端实例
async function getClient() {
  if (!mongoClient) {
    mongoClient = new MongoClient(url);
    await mongoClient.connect();
  }
  return mongoClient;
}

export async function addComment(reqBody) {
  const client = await getClient();
  const db = client.db();

  try {
    const result = await db
      .collection("posts")
      .updateOne(
        { _id: new ObjectID(reqBody.ID) },
        { $push: { postComments: reqBody.newComment } }
      );
    return result;
  } catch (err) {
    // 按需处理错误，比如日志记录或抛给上层
    throw err;
  }
  // 不要手动关闭客户端，连接池会自动管理连接的复用与回收
}

这种方式下，服务器启动后只会创建一次MongoClient并建立连接池，后续所有请求复用该连接池中的连接，不会触发连接数过多的警告。

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