Node.js异步Firestore代码执行顺序异常原因排查

我编写了一个查询Firestore数据库的接口，逻辑如下：

1. 查询eventGeoHashes集合获取所有文档
2. 若文档包含eventHash字段（指向另一Firestore文档的引用），则获取该关联文档并将其数据注入原文档
3. 收集所有处理后的文档，通过res.send()返回响应

但实际运行时，res.send()会在所有文档处理完成前就执行，导致返回的响应不完整。我的代码如下：

eventsRouter.get("/", async (req: Request, res: Response) => {
  const response: DocumentData[] = [];
  await getDocs(collection(db, "eventGeoHashes"))
    .then((docs) => {
      docs.forEach(async (doc) => {
        const data = doc.data();
        if (data.hasOwnProperty("eventHash")) {
          const eventRef: DocumentReference = data.eventHash;
          await getDoc(eventRef).then((event) => {
            data.event = event.data();
          });
        }
        response.push(data);
      });
    })
    .then(() => res.send(response));
});

原因分析 #

核心问题是**Array.prototype.forEach不支持异步函数的等待机制**：

• 你在forEach的回调中使用了async/await处理Firestore的异步查询，但forEach会直接遍历所有元素，不会等待每个异步回调执行完毕。
• 外层的.then(() => res.send(response))会在forEach遍历结束（而非所有异步操作完成）后立即执行，此时response数组还未被完全填充，所以返回的结果不完整。

解决方案 #

方案1：使用for...of循环（串行处理） #

for...of可以配合await，确保每个异步操作完成后再处理下一个文档：

eventsRouter.get("/", async (req: Request, res: Response) => {
  const response: DocumentData[] = [];
  // 先获取集合快照
  const docsSnapshot = await getDocs(collection(db, "eventGeoHashes"));
  
  // 用for...of遍历，等待每个异步操作完成
  for (const doc of docsSnapshot.docs) {
    const data = doc.data();
    if (data.hasOwnProperty("eventHash")) {
      const eventRef: DocumentReference = data.eventHash;
      const eventDoc = await getDoc(eventRef);
      data.event = eventDoc.data();
    }
    response.push(data);
  }
  
  // 所有处理完成后再返回响应
  res.send(response);
});

方案2：使用Promise.all（并行处理，效率更高） #

通过Promise.all批量发起所有异步请求，等待所有请求完成后再收集结果，适合文档数量较多的场景（注意Firestore的并发请求限制）：

eventsRouter.get("/", async (req: Request, res: Response) => {
  const docsSnapshot = await getDocs(collection(db, "eventGeoHashes"));
  
  // 用map生成所有异步任务，通过Promise.all等待全部完成
  const response = await Promise.all(
    docsSnapshot.docs.map(async (doc) => {
      const data = doc.data();
      if (data.hasOwnProperty("eventHash")) {
        const eventRef: DocumentReference = data.eventHash;
        const eventDoc = await getDoc(eventRef);
        data.event = eventDoc.data();
      }
      return data;
    })
  );
  
  res.send(response);
});

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