Node.js中Async.each执行异常问题求助

你的代码核心问题是没有正确处理异步操作的回调时机，同时忽略了错误处理，导致数据库查询还没完成就提前结束了循环，最终返回的category数组是空的或者不完整。下面是具体的问题点和修复后的代码：

主要问题点 #

• 你在req.models.aswdf.find的异步回调外部调用了callback()，这会让async.each误以为当前迭代已经完成，但此时数据库查询可能还在执行，结果还没写入category
• 没有捕获数据库查询的错误，一旦查询出错，整个流程无法感知到异常
• return done(...)写在async.each的外部，会在所有异步查询完成前就执行，导致返回的category还没被填充

修复后的完整代码 #

// 假设category是在当前作用域提前声明的数组
const category = [];

async.each(asd, (items, callback) => {
  req.models.aswdf.find({ id: items.id }, function (err, result) {
    // 第一步：处理数据库查询的错误
    if (err) {
      return callback(err); // 把错误传递给async.each，终止流程
    }
    // 第二步：处理查询结果为空的情况，避免result[0]报错
    if (!result || result.length === 0) {
      return callback(new Error(`No data found for id: ${items.id}`));
    }
    // 第三步：将结果推入数组
    category.push(result[0].asd);
    // 第四步：当前迭代完成，调用callback通知async.each
    callback();
  });
}, (err) => {
  // 所有迭代完成后的回调
  if (err) {
    return next(err, null); // 传递错误给中间件
  }
  // 所有异步查询完成后，再调用done返回结果
  return done(null, {
    displayName: people[0].fullName(),
    id: people[0].id,
    email: people[0].email,
    role: category
  });
});

关键修复说明 #

1. 回调时机调整：把callback()移到find方法的回调内部，确保只有当数据库查询完成（拿到结果或错误）后，才标记当前迭代完成
2. 错误处理完善：捕获数据库查询的错误，并通过callback(err)传递给async.each的最终回调，这样错误会被next(err, null)处理
3. 结果安全校验：增加对result的非空判断，避免result[0]触发Cannot read properties of undefined的错误
4. 返回时机修正：把done()调用放在async.each的最终回调里，确保所有异步查询完成、category数组填充完毕后，再返回结果

另外，注意确认你使用的是async库（需要先通过npm install async安装，并且在代码中const async = require('async')引入），如果是原生的Array.prototype.forEach，那它不支持异步迭代，必须用async.each或者其他异步迭代方案（比如for...of配合async/await）。

如果你更倾向于用现代的async/await语法，也可以改写为更易读的版本：

const category = [];

try {
  for (const item of asd) {
    const result = await req.models.aswdf.find({ id: item.id });
    if (!result || result.length === 0) {
      throw new Error(`No data found for id: ${item.id}`);
    }
    category.push(result[0].asd);
  }
  return done(null, {
    displayName: people[0].fullName(),
    id: people[0].id,
    email: people[0].email,
    role: category
  });
} catch (err) {
  return next(err, null);
}

这个版本用for...of配合await，避免了嵌套回调，代码可读性更高，也更容易维护。

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