Node.js Mongoose REST API中函数执行后对象值丢失问题排查

你的问题核心是异步操作的时序控制不当——你在同步循环里触发了多次Mongoose异步查询，但这些查询的回调函数会在主程序逻辑（循环外的console.log和test.save）执行完之后才运行，所以当你试图使用test.questions时，里面还没有数据。

为什么初始代码会失败？ #

你的while循环是同步执行的，5次循环会立刻触发5次count()和findOne()查询，但这些都是异步IO操作，它们的回调会被放进事件队列等待执行。而主栈的代码会继续往下走：循环结束后立刻打印test.questions、调用test.save()，这时候所有异步回调还没开始执行，questions数组自然是空的。

另外提一句：Mongoose的count()方法已经被废弃了，建议改用countDocuments()。

你的asyncLoop尝试哪里不对？ #

你把while循环放进了asyncLoop的回调里，这会一次性触发所有异步查询，本质上和初始代码的问题一样——没有真正控制异步操作的完成时机，next()的调用时机也不对，导致最终还是拿不到数据。

正确的解决方案：用async/await控制异步时序 #

现代JavaScript的async/await语法可以让异步代码看起来像同步代码，完美解决时序问题。这里给出两种实现方式，还顺便优化了“避免抽到重复题目”的问题：

方案1：串行查询（适合需要严格顺序的场景）

randomizeTest = async (req, res) => {
  try {
    const test = new Test();
    const questions = [];
    const requiredCount = 5;

    // 获取总题数（替换废弃的count()）
    const totalQuestions = await this.quesmodel.countDocuments();

    // 生成5个不重复的随机索引，避免抽到同一道题
    const randomIndexes = new Set();
    while (randomIndexes.size < requiredCount) {
      randomIndexes.add(Math.floor(Math.random() * totalQuestions));
    }

    // 逐个查询题目，确保前一个查询完成后再进行下一个
    for (const index of randomIndexes) {
      const question = await this.quesmodel.findOne().skip(index);
      questions.push(question._id);
    }

    test.questions = questions;
    console.log(test.questions); // 现在能正确打印出ID数组了

    // 保存测试文档
    const savedTest = await test.save();
    res.status(200).json({ test: savedTest });
  } catch (err) {
    res.sendStatus(400);
    console.error(err);
  }
};

方案2：并行查询（效率更高，适合批量操作）

如果不需要严格的查询顺序，用Promise.all并行处理所有查询，速度会更快：

randomizeTest = async (req, res) => {
  try {
    const test = new Test();
    const requiredCount = 5;

    const totalQuestions = await this.quesmodel.countDocuments();
    const randomIndexes = new Set();
    while (randomIndexes.size < requiredCount) {
      randomIndexes.add(Math.floor(Math.random() * totalQuestions));
    }

    // 把所有查询任务变成Promise，并行执行
    const questionPromises = Array.from(randomIndexes).map(index => 
      this.quesmodel.findOne().skip(index)
    );
    const questionResults = await Promise.all(questionPromises);
    
    // 提取所有题目的ID
    const questions = questionResults.map(question => question._id);

    test.questions = questions;
    console.log(test.questions);

    const savedTest = await test.save();
    res.status(200).json({ test: savedTest });
  } catch (err) {
    res.sendStatus(400);
    console.error(err);
  }
};

关键优化点 #

1. async/await替代回调：让异步代码的执行顺序更直观，避免回调地狱。
2. 去重随机索引：用Set确保不会抽到重复的题目（如果业务允许重复，可以去掉这部分逻辑）。
3. 错误统一处理：用try/catch捕获所有异步操作的错误，比分散的回调错误处理更简洁。
4. 废弃方法替换：用countDocuments()替代已废弃的count()，符合Mongoose的最新规范。

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