Node.js中使用Promise.all等待所有request请求完成的相关问题

1. 直接将request.get返回值传入Promise.all的方式是否正确？ #

不正确。因为request模块默认的回调式API返回的是一个请求对象（如http.ClientRequest实例），并非Promise对象。Promise.all只能接收Promise实例组成的数组，所以这种写法不会等待所有请求的回调执行完成，then里的逻辑会直接触发，达不到“所有请求回调完成后执行统一逻辑”的效果。

2. request回调中Promise的resolve时机由什么决定？ #

request本身不内置Promise支持，你用到的Promise是手动封装出来的（比如你提供的doRequest函数）。Promise的resolve时机完全由你在回调函数里调用resolve()的位置决定：

• 如果在回调函数开头调用resolve()，Promise就会在回调执行开始时完成；
• 如果在回调函数末尾（比如做完所有日志、数据处理后）调用resolve()，Promise会等这些操作完成后才完成。

注意：request的回调本身是在请求拿到响应、数据接收完成后才触发的，但Promise何时resolve完全由你写的代码控制。

示例说明：

function doRequest(url) {
  return new Promise(function (resolve, reject) {
    request(url, function (error, res, body) {
      console.log('回调开始执行');
      // 此处调用resolve，Promise会立刻完成
      // resolve(body);
      
      // 模拟处理逻辑
      setTimeout(() => {
        console.log('处理完成');
        // 此处调用resolve，Promise会等定时器结束后才完成
        resolve(body);
      }, 1000);
    });
  });
}

3. 如何用封装的doRequest处理多个请求？ #

可以把多个doRequest调用组成数组，配合Promise.all实现“所有请求完成后执行统一逻辑”的需求，以下是两种常见写法：

写法1：Promise.all + then/catch #

function doRequest(url) {
  return new Promise(function (resolve, reject) {
    request(url, function (error, res, body) {
      if (!error && res.statusCode === 200) {
        resolve(body);
      } else {
        reject(error || new Error(`请求失败，状态码：${res.statusCode}`));
      }
    });
  });
}

// 准备请求URL数组
const urls = [
  'https://url1.com',
  'https://url2.com',
  'https://url3.com',
  // ... 更多URL
];

// 生成Promise数组
const requestPromises = urls.map(url => doRequest(url));

// 等待所有请求完成
Promise.all(requestPromises)
  .then(allResponses => {
    // allResponses结果顺序与urls数组一致
    console.log('所有请求完成：', allResponses);
  })
  .catch(error => {
    // 任一请求失败都会进入这里
    console.error('请求失败：', error);
  });

写法2：async/await（更简洁） #

async function handleMultipleRequests() {
  try {
    const urls = ['https://url1.com', 'https://url2.com', 'https://url3.com'];
    const requestPromises = urls.map(url => doRequest(url));
    const allResponses = await Promise.all(requestPromises);
    console.log('所有请求完成：', allResponses);
  } catch (error) {
    console.error('请求失败：', error);
  }
}

// 执行函数
handleMultipleRequests();

补充：如果需要兼容部分请求失败的场景（即即使有请求失败，也能拿到所有请求的结果），可以用Promise.allSettled代替Promise.all，它会返回每个请求的状态（成功/失败）和对应结果。

内容的提问来源于stack exchange，提问作者C.Unbay