Node.js对接MongoDB频繁读写导致高并发下服务器卡死，如何优化？

• 最致命的错误：db.close() 写在for循环内部，第一次循环执行完直接关闭数据库连接，后续所有循环的数据库操作都会因连接失效挂起，大量请求堆积直接导致服务卡死
• 串行执行逻辑：for循环内用await串行执行单条用户的查询+写入操作，N个用户就要等N次数据库IO往返，耗时是单条的N倍，高并发场景下请求阻塞严重
• 多余的查询开销：先执行findOne判断用户是否存在，再决定更新或插入，每次操作多一次不必要的数据库查询请求
• 无批量操作逻辑：所有数据库操作都是单条执行，频繁的网络IO和数据库请求会耗尽数据库连接池资源
• 大概率缺失索引：如果userid字段没有设置唯一索引，findOne、update的查询效率会随数据量增长线性下降，进一步拖慢响应速度

1. 修复数据库连接关闭的逻辑 #

全局复用初始化好的db连接，不要在业务逻辑里随意关闭连接，连接的释放由monk内部的连接池统一管理，直接删掉for循环里的db.close()代码即可。

2. 替换单条判断逻辑为upsert操作 #

MongoDB的update操作自带upsert参数，匹配到文档就更新，没匹配到就自动插入，不需要提前查询判断，直接把三次数据库操作（查+更/插）合并为1次：

await dbUser.findOneAndUpdate(
  { userid: memberID }, 
  { $set: { username: memberUsername, isleft: 0 } },
  { upsert: true }
)

3. 改成批量操作减少IO次数 #

把批量用户的操作合并为单次批量写入请求，不用循环单条执行，极大降低网络IO和数据库请求次数：

// 先构造所有用户的批量操作指令
const operations = msg.members.map(member => ({
  updateOne: {
    filter: { userid: member.id },
    update: { $set: { username: member.username, isleft: 0 } },
    upsert: true
  }
}))
// 一次性执行所有批量操作
await dbUser.bulkWrite(operations)

4. 给查询字段加索引提升效率 #

给userid字段添加唯一索引，既可以加速查询效率，也可以避免重复插入相同userid的脏数据：

// 只需执行一次，可以在服务启动时初始化
await dbUser.createIndex({ userid: 1 }, { unique: true })

5. 并发控制优化 #

如果单批用户量过大（比如超过1000），可以做分批处理，避免单次批量请求过大导致数据库压力过高，每批控制在200-500条左右即可。

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