开发聊天应用时向已存在聊天室发消息无法存入messages数组求助

问题排查 #

你代码中存在3个直接导致消息无法存入数组的问题：

• 变量作用域错误：message、sender两个变量仅在chat === null的if分支内完成赋值，进入已有聊天室的else分支时，两个变量为未赋值状态，无法写入有效内容。
• 异步操作未等待：chat.save()是返回Promise的异步方法，当前代码未等待save操作执行完成就直接返回响应，会出现数据库还没完成写入就返回旧数据的问题，save过程中抛出的错误也无法捕获。
• Schema定义不兼容风险：需确认Chat模型的messages字段定义为数组类型，参考正确定义：

const chatSchema = new mongoose.Schema({
  chatroomId: String,
  messages: [{
    message: String,
    sender: String,
    createAt: { type: Date, default: Date.now }
  }]
})

如果messages被定义为Object类型，将不支持push方法。

修复后代码示例 #

.post(isUser, async (req, res, next) => {
  try {
    const classId = req.userId + ' ' + req.params.matchId
    // 变量提前统一赋值，避免作用域问题
    const message = req.body.message
    const sender = req.userId
    const chat = await Chat.findOne({ chatroomId: classId })
    
    if (chat === null) {
      const newChat = await Chat.create({
        chatroomId: classId,
        messages: [{ message, sender }]
      })
      res.status(200).json(newChat)
    } else {
      chat.messages.push({ message, sender })
      // 等待save完成再返回
      await chat.save()
      res.status(200).json(chat)
    }
  } catch (err) {
    next(err)
  }
})

聊天应用开发优化建议 #

• 实时消息传输改用WebSocket方案，可直接使用Socket.io库，相比普通HTTP请求可以实现服务端主动向客户端推送消息，不需要前端轮询拉取新消息，实时性和性能表现更好。
• 新增消息唯一ID、发送时间戳、消息状态（发送中/已发送/已读）字段，方便后续做消息撤回、已读统计、消息时序排序等功能。
• 聊天室消息量大之后可拆分存储，不要全部存在同一个文档的messages数组中，避免单文档体积过大导致查询性能下降。
• 增加接口参数校验，过滤空消息、非法用户ID的无效请求。

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