递归Promise未返回结果问题排查

从你提供的代码片段来看，这个递归Promise出现未返回结果的核心原因是Promise链在递归分支中被中断了，具体问题和修复方案如下：

关键问题分析 #

• else分支未返回Promise：当missingItems != 0时，你发起了http.get请求，但这段异步逻辑没有被包裹在Promise中并返回，导致外层的missingItemsPromise()调用无法等待这个异步操作完成，直接提前结束。
• 递归调用未衔接Promise链：即使你在http响应处理里调用了missingItemsPromise()，如果没有把这个递归调用的Promise返回出去，整个Promise链还是会断裂，上层无法感知后续的递归执行状态。
• 回调式API未Promise化：http.get是基于回调的异步API，没有包装成Promise的话，无法和你的递归Promise逻辑正确结合，导致异步操作的状态无法被追踪。

修复后的代码示例 #

function missingItemsPromise() {
  return new Promise((resolve, reject) => {
    if (missingItems == 0) {
      console.log('resolves');
      console.log(products);
      return resolve();
    } else {
      page++;
      url = getUrl(id, page);
      // 将http.get回调逻辑包裹为Promise并返回，衔接外层Promise链
      return new Promise((innerResolve, innerReject) => {
        http.get(url, function(xres) {
          xres.setEncoding('utf8');
          let fullBody = '';
          // 注意：data事件可能分多次触发，需拼接完整响应内容
          xres.on('data', function(chunk) {
            fullBody += chunk;
          });
          xres.on('end', function() {
            console.log('calling');
            try {
              const xtraJson = JSON.parse(fullBody);
              const xtraProducts = xtraJson['products'];
              products = products.concat(xtraProducts);
              productsLength = products.length;
              // 这里补充你代码中省略的missingItems更新逻辑
              missingItems = /* 比如：总待获取数量 - productsLength */;
              // 递归调用并将结果传递给当前Promise的resolve，延续链条
              missingItemsPromise().then(innerResolve).catch(innerReject);
            } catch (parseErr) {
              innerReject(parseErr); // 捕获JSON解析错误
            }
          });
          xres.on('error', innerReject); // 捕获响应流错误
        }).on('error', innerReject); // 捕获请求发起错误
      });
    }
  });
}

核心修复点说明 #

1. Promise化http.get：把回调式的请求逻辑包裹到新的Promise中，通过innerResolve和innerReject来控制这个异步操作的完成状态，让递归分支能返回一个可被等待的Promise。
2. 衔接递归Promise链：在处理完响应数据后，递归调用missingItemsPromise()时，通过then把递归的结果传递给当前Promise的resolve，确保整个Promise链是连续的，上层能等待所有递归步骤完成。
3. 完整处理响应数据：原来的代码只监听了一次data事件，但HTTP响应可能分多次传输，需要拼接完整的响应体后再解析JSON，避免出现解析失败的情况。
4. 添加错误处理：补充了请求错误、响应流错误和JSON解析错误的捕获，避免Promise被静默失败，方便排查后续问题。

这样修改后，整个递归的Promise链就能正确衔接，每一次递归的异步操作都会被上层Promise等待，最终当missingItems == 0时，整个Promise会正确resolve，返回预期的结果。

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