MongoDB多关联集合操作异常时的已创建文档回滚方案咨询

针对你提出的业务场景，「出错后删除对应集合最新记录」的方案存在并发安全隐患（高并发下可能误删其他请求创建的记录），以下是更可靠的实现方式：

1. 多文档事务（首选方案） #

MongoDB 4.0+副本集、4.2+分片集群支持多文档事务，能将整个业务流程包装在原子事务中，任一环节出错时自动回滚所有已执行的写操作，无需手动删除。

代码示例（Node.js + Mongoose） #

const session = await mongoose.startSession();
session.startTransaction();

try {
  // 1. 检查并创建客户记录
  let customer = await Customer.findOne({ userId: req.body.userId }).session(session);
  if (!customer) {
    customer = await Customer.create(
      [{ ...req.body.customerInfo }], 
      { session }
    )[0];
  }

  // 2. 创建奖励记录
  const reward = await Reward.create(
    [{ customerId: customer._id, ...req.body.rewardInfo }], 
    { session }
  )[0];

  // 注意：邮件发送属于外部操作，事务无法回滚，需单独处理补偿
  await sendRewardEmail(customer.email, reward);

  // 3. 检查问卷是否存在，不存在则创建
  const existingSurvey = await Survey.findOne({
    customerId: customer._id,
    surveyId: req.body.surveyId
  }).session(session);

  if (existingSurvey) throw new Error("该问卷已提交");
  await Survey.create(
    [{ customerId: customer._id, ...req.body.surveyInfo }], 
    { session }
  );

  // 提交事务，所有操作生效
  await session.commitTransaction();
} catch (err) {
  // 回滚事务，自动撤销已创建的customer、reward、survey记录
  await session.abortTransaction();
  
  // 邮件补偿逻辑：如果已发送邮件，需手动处理（比如发送撤销通知或记录待处理任务）
  if (err.message.includes("奖励邮件已发送")) {
    // 这里添加邮件补偿代码
  }
  throw err;
} finally {
  session.endSession();
}

2. 预检查+补偿机制（兼容旧版MongoDB） #

若无法使用事务，可通过「预检查前置+唯一索引+定向补偿」实现：

• 预检查前置：先执行所有合法性校验（客户是否存在、问卷是否重复），校验不通过直接报错，不进入写流程
• 唯一索引保障：给customer.userId、survey.customerId+surveyId、reward.customerId+rewardType添加唯一索引，避免重复创建
• 定向补偿删除：出错时根据业务唯一标识（而非最新记录）删除已创建数据，比如通过userId删除客户、customerId删除奖励记录

核心逻辑示例 #

async function handleSurveySubmit(req) {
  // 预检查：先确认问卷未提交
  const existingSurvey = await Survey.findOne({
    customerId: req.body.userId,
    surveyId: req.body.surveyId
  });
  if (existingSurvey) throw new Error("该问卷已存在");

  let createdCustomer = null;
  let createdReward = null;

  try {
    // 创建客户（不存在时）
    createdCustomer = await Customer.findOneAndUpdate(
      { userId: req.body.userId },
      { $setOnInsert: req.body.customerInfo },
      { upsert: true, new: true }
    );

    // 创建奖励记录
    createdReward = await Reward.create({
      customerId: createdCustomer._id,
      ...req.body.rewardInfo
    });

    // 发送邮件
    await sendRewardEmail(createdCustomer.email, createdReward);

    // 创建问卷
    await Survey.create({
      customerId: createdCustomer._id,
      ...req.body.surveyInfo
    });
  } catch (err) {
    // 定向删除已创建的记录
    if (createdReward) await Reward.findByIdAndDelete(createdReward._id);
    if (createdCustomer && createdCustomer.isNew) await Customer.findByIdAndDelete(createdCustomer._id);
    
    // 邮件补偿逻辑
    if (err.message.includes("邮件发送成功")) {
      // 处理已发送邮件的补偿
    }
    throw err;
  }
}

3. 事件驱动最终一致性（分布式场景） #

如果业务涉及多个服务，可通过事件总线实现最终一致性：

• 每个操作完成后发布事件（如CustomerCreated、RewardCreated）
• 监听失败事件（如SurveyCreationFailed），触发补偿事件（CustomerDeleted、RewardDeleted）
• 用事件存储记录所有操作轨迹，确保补偿可追溯

关键注意点 #

• 绝对避免依赖「删除最新记录」的逻辑，高并发下会误删其他请求的数据
• 外部操作（如邮件发送）无法通过事务回滚，必须单独设计补偿机制

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