Express使用.map()更新会话参与方User模型数据异常问题咨询

问题产生原因 #

• 异步遍历方法使用错误：直接使用await conversators.map(...)是无效的，map返回的是包含多个异步函数的Promise数组，单个await不会等待所有异步操作执行完成，会导致后续逻辑提前执行，部分更新操作丢失。
• 用户查询条件错误：findOneAndUpdate的查询参数写为{ user: conversator }，但User模型中根本没有user字段，主键为_id，错误的查询条件会导致始终匹配不到目标用户，或者匹配到非预期的用户，这是每次打印同一个User的核心原因。
• 更新操作语法错误：$set: { newData }的写法相当于给User文档新增了一个名为newData的自定义字段，根本没有修改原有的conversations字段，更新自然不生效。
• 会话保存时序错误：在会话conversation还未执行save()操作时就取用conversation.id，部分场景下Mongoose还未生成正式的文档ID，会导致存入的ID无效。
• 冗余操作：已经通过findById拿到了用户实例，完全可以直接修改实例属性后调用save()，不需要再执行findOneAndUpdate，重复操作还容易引发错误。

修复后的代码 #

router.post(
  "/",
  auth,
  [
    check("conversators", "There should be at least two conversators").isLength(
      { min: 2 }
    ),
  ],
  async (req, res) => {
    const { conversators } = req.body;
    const errors = validationResult(req);

    if (!errors.isEmpty()) {
      return res.status(400).json({ errors: errors.array() });
    }

    try {
      let conversation = new Conversation({
        user: req.user.id,
        conversators: conversators,
      });
      // 提前保存会话，确保生成稳定有效的会话ID
      await conversation.save();

      // 用Promise.all等待所有用户更新操作执行完成
      await Promise.all(conversators.map(async (conversator) => {
        let user = await User.findById(conversator);
        // 容错处理，避免非法用户ID导致服务崩溃
        if (!user) return;
        // 直接修改用户实例的会话列表
        user.conversations.push(conversation.id);
        // 保存修改
        await user.save();
        console.log('更新后的用户', user);
      }));

      res.status(200).json(conversation);
    } catch (error) {
      console.error(error.message);
      res.status(500).send("Server error.");
    }
  }
);

module.exports = router;

可选优化（原子更新，避免并发冲突） #

如果不需要对用户实例做其他额外逻辑处理，可以直接用updateOne配合$push实现原子更新，不需要先查再改，性能更高，也不会出现并发修改冲突：

await Promise.all(conversators.map(async (conversator) => {
  await User.updateOne(
    { _id: conversator },
    { $push: { conversations: conversation.id } }
  );
}));

提示：如果你的conversators数组不包含发起会话的当前用户req.user.id，可以根据业务需要决定是否额外更新当前用户的会话列表。

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