MERN栈社交应用：如何安全同时保存两个用户连接文档？

直接分开调用await connection.save()和await senderConnection.save()确实存在数据不一致风险——如果第一个保存成功，第二个失败，就会出现一方的连接状态已更新，另一方还是旧状态的情况，这在社交关系场景下会导致逻辑混乱。

最稳妥的解决方案是使用Mongoose事务，它能保证一组数据库操作要么全部成功提交，要么全部失败回滚，从根本上避免数据不一致。

实现步骤 #

1. 确保MongoDB环境支持事务 #

Mongoose事务依赖MongoDB的副本集模式，本地开发可以通过以下方式启动单节点副本集：

mongod --replSet rs0

然后进入MongoDB shell执行初始化：

rs.initiate()

2. 事务版接受请求逻辑示例 #

假设你的Connection模型结构包含用户ID和连接列表（带状态字段），下面是路由处理的完整代码：

const mongoose = require('mongoose');
const Connection = require('../models/Connection'); // 引入你的连接模型

router.put('/api/connections/acceptrequest/:user_id', async (req, res) => {
  // 开启会话
  const session = await mongoose.startSession();
  session.startTransaction();

  try {
    const currentUserId = req.user._id; // 从认证中间件获取当前用户ID
    const senderUserId = req.params.user_id;

    // 1. 更新当前用户的连接文档：将发送方的请求状态改为accepted
    const currentConn = await Connection.findOneAndUpdate(
      { userId: currentUserId, 'connections.targetUserId': senderUserId },
      { $set: { 'connections.$.status': 'accepted' } },
      { session, new: true } // 指定session，确保操作在事务内
    );

    if (!currentConn) {
      throw new Error('未找到对应的连接请求');
    }

    // 2. 更新发送方的连接文档：将当前用户的请求状态改为accepted
    const senderConn = await Connection.findOneAndUpdate(
      { userId: senderUserId, 'connections.targetUserId': currentUserId },
      { $set: { 'connections.$.status': 'accepted' } },
      { session, new: true }
    );

    if (!senderConn) {
      throw new Error('发送方的连接记录不存在');
    }

    // 提交事务：两个操作都成功才会生效
    await session.commitTransaction();
    res.status(200).json({
      message: '连接请求已接受',
      currentUserConnections: currentConn.connections,
      senderConnections: senderConn.connections
    });
  } catch (err) {
    // 回滚事务：任何一步失败，所有操作都会撤销
    await session.abortTransaction();
    res.status(500).json({ error: err.message });
  } finally {
    // 无论成功失败，结束会话
    session.endSession();
  }
});

3. 关键注意事项 #

• 所有需要纳入事务的数据库操作，必须显式指定session参数，否则操作会脱离事务控制
• 使用findOneAndUpdate替代先查询再save的方式，减少中间状态暴露的风险，同时提升性能
• 事务仅在MongoDB 4.0+版本的副本集/分片集群中支持，若环境受限，可考虑手动实现补偿逻辑（但可靠性远低于事务）

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