Node.js promise.each遍历数组时最后一个元素结果未捕获问题

听起来你遇到的问题很典型——在使用promise.each处理异步任务时，最后一个元素的结果没有被正确捕获，而且还要保证重复主机对应的结果数量和原数组一致。我来帮你分析下常见原因和解决办法：

核心问题排查点 #

1. 确保每个主机的处理逻辑完整返回Promise #

promise.each（不管是Bluebird还是其他库的实现）依赖每个迭代回调返回的Promise来控制流程。如果你的处理函数没有正确返回Promise链，就可能导致最后一个元素的异步操作还没完成，遍历就提前结束了。

比如很多人会犯这样的错误：

// 错误示例：没有返回Promise
Promise.each(hostList, (host) => {
  mysql.createConnection(...)
    .then(conn => conn.query(...))
    .then(result => results.push(result));
  // 这里没有返回Promise，promise.each会直接进入下一个迭代
});

2. 结果数组的更新要同步于Promise的完成 #

不要在异步回调里直接push结果，而是要在await或者then的同步代码块里更新数组，确保每个元素的结果都被正确添加。

3. 重复主机要独立处理 #

即使主机名相同，也要为每个数组元素创建独立的连接和查询流程，不要复用连接或者跳过处理，这样才能保证结果数组的长度和原数组一致。

修正后的示例代码 #

我用mysql2/promise（原生支持Promise的MySQL库）和Bluebird的promise.each来写一个可靠的实现：

const Promise = require('bluebird');
const mysql = require('mysql2/promise');

// 单个主机的处理函数：返回包含结果或错误的对象
async function handleSingleHost(host) {
  let connection;
  try {
    // 建立连接
    connection = await mysql.createConnection({
      host: host,
      user: 'your_username',
      password: 'your_password',
      database: 'target_db'
    });

    // 执行查询
    const [queryResults] = await connection.execute('SELECT * FROM your_table');
    
    // 返回成功结果
    return {
      host: host,
      success: true,
      data: queryResults
    };
  } catch (error) {
    // 捕获错误，返回错误信息（避免终止整个遍历）
    return {
      host: host,
      success: false,
      error: error.message
    };
  } finally {
    // 确保连接关闭，避免资源泄漏
    if (connection) {
      await connection.end();
    }
  }
}

// 遍历所有主机的主函数
async function processHostList(hostArray) {
  const finalResults = [];

  await Promise.each(hostArray, async (currentHost) => {
    // 等待当前主机处理完成，再添加到结果数组
    const hostResult = await handleSingleHost(currentHost);
    finalResults.push(hostResult);
  });

  return finalResults;
}

// 使用示例
const testHosts = ['host1', 'host2', 'host1', 'host3'];
processHostList(testHosts)
  .then(results => {
    console.log('最终结果：', JSON.stringify(results, null, 2));
    console.log(`结果数量：${results.length}，原数组数量：${testHosts.length}`);
  })
  .catch(globalError => {
    console.error('遍历过程中发生全局错误：', globalError);
  });

关键说明 #

• handleSingleHost用async/await包裹了所有异步操作，确保返回的Promise只有在连接、查询、关闭连接都完成后才会resolve。
• Promise.each的回调用async函数，配合await等待每个主机的处理结果，保证遍历是串行的，且每个结果都被正确push到数组。
• finally块保证无论成功还是失败，连接都会被关闭，避免资源泄漏。
• 即使主机名重复，每个数组元素都会独立执行handleSingleHost，所以结果数组的长度和原数组完全一致。

如果之前的代码没有处理这些点，比如忘记返回Promise、没有等待异步操作完成，就会出现最后一个元素结果丢失的情况。你可以对照这个示例检查你的代码，应该就能解决问题了。

内容的提问来源于stack exchange，提问作者Valerian Pereira