Request/forLoop/Promise 嵌套娃娃地狱 - Node JS

Question

我使用的 API 具有一些有限的功能，并且我正在尝试组合对多个路由的多个调用，以根据单个关键字搜索为用户提供特定信息。这在 for 循环中创建了许多单独的请求，这些请求本身在其他请求结果的回调中，等等。最后我无法等待所有嵌套请求完成，直到我解决了原始的 Promise 和我的模板引擎呈现页面并响应用户的获取请求。因此，模板引擎正在呈现一个结果数组仍然为空的页面。

        let discoveredMovies = [];
        let personSearchCast = new Promise ((resolve) => {
            request(UserSearchParamsURL1, {json:true}, (err, res, body) =>{
                if (err) { 
                    console.log(err); 
                    resolve();
                }
                else if(!body.results.length || !body) { 
                    resolve();
                }
                else {
                    for (const person of body) {
                        request(URL2, {json: true}, (err, res2, body2) => {
                            for (const movie of body2) {
                                    request(URL3, {json:true}, (err, res3, body3) => {
                                        movie[CertainParam] = false;

                                        if (Certain Conditions) {
                                            discoveredMovies.push(movie);
                                        }
            
                                        if (Other Conditions) {
                                            discoveredMovies.push(movie);
                                        }
                                        if(More Conditions) {
                                            movie[CertainParam] = true;
                                            Object.assign(movie, {body3info: body3});
                                        }
        
                                        resolve();
                
                                });
                            };
                        });
                    };
                }
            });
        });
        
        personSearchCast.then(() => {
            res.render("partials/foundpeoplemovies.ejs", {movies: discoveredMovies});
        });

就目前而言，我知道所有请求调用都会发生，因为我可以将它们注销，但模板在它们完成之前呈现。我已经尝试创建几个异步等待函数并尝试连接它们，但我就是无法理解它。我还尝试使用计数器来调节 resolve() 直到循环内的所有循环都完成，但这也没有让我走得太远。

我知道代码很乱，但是有什么想法可以干净地完成我想做的事情吗？否则我将不得不弄乱用户界面并为用户添加一系列间歇性步骤，而不是在一次快速搜索中为用户提供所有信息。

Answer 1

为了回应 Bergi 的评论，您需要“承诺”您的 request 函数 -

async function requestJson(url) {
  return new Promise((resolve, reject) =>
    request(url, {json: true}, (err, res, body) => {
      if (err)
        reject(err)
      else
        resolve({ res, body })
    })
  )
}

现在您可以按预期使用 Promises -

async function searchCast(URL1) {
  const discoveredMovies = []
  const { body: cast } = await requestJson(URL1)
  for (const actor of cast) {
    const { body: movies } = await requestJson(URL2)
    for (const movie of movies) {
      const { body: details } = await requestJSON(URL3)
      if (details[CertainParam] == someCondition)
        discoveredMovies.push({ movie, details })
    }
  }
  return discoveredMovies
}

下面是如何在网络表单中使用 searchCast 的示例 -

myForm.addEventListener("submit", async event => {
  try {
    const searchUrl = ...
    const discoveredMovies = await searchCast(searchUrl)
    console.log(discoveredMovies)
  }
  catch (err) {
    console.error(err.message)
  }
})

像我们上面那样使用for 循环将导致串行查询，即movies 子查询必须在移动到下一个之前完成。您可以并行使用 Promise.all 到运行所有子查询。另一种选择是对 Pool 到 limit/throttle 多个请求进行建模，以防止远程 API 泛滥。 .

中描述了这种技术

Request/forLoop/Promise 嵌套娃娃地狱 - Node JS

Request/forLoop/Promise Nesting Doll Hell - Node JS

javascript

request

node.js

promise

express