我有以下代码:

var request = require('request');
var cheerio = require ("cheerio");
var async= require("async");

var MyLink="www.mylink.com";

    async.series([

        function(callback){
            request(Mylink, function (error, response, body) {
                if (error) return callback(error); 
                var $ = cheerio.load(body);
                //Some calculations where I get NewUrl variable...
                TheUrl=NewUrl;
                callback();
            });
        },
        function(callback){
            for (var i = 0; i <=TheUrl.length-1; i++) {
                var url = 'www.myurl.com='+TheUrl[i];
                request(url, function(error, resp, body) { 
                    if (error) return callback(error); 
                    var $ = cheerio.load(body);
                    //Some calculations again...
                    callback();
                });
            };
        }
      ], function(error){
        if (error) return next(error);
    });

有没有人建议我如何在 for 循环 中延迟每个循环迭代？比如说，代码在每次迭代完成后等待 10 秒。我尝试了 setTimeout 但没有成功。

最佳答案

使用 async/await

我是异步库的忠实拥护者，并且我已经使用了很长时间。但是，现在有 async/await .您的代码变得更易于阅读。例如，这将是您的主要功能:

const urls = await fetchUrls(INITIAL_URL);

for (const url of urls) {
    await sleep(10000);
    const $ = await fetchPage(url);
    // do stuff with cheerio-processed page
}

好多了，不是吗？在详细了解 fetchPage() 和 fetchUrls() 的工作原理之前，让我们首先回答您的问题，即如何在获取下一页之前等待。 sleep 函数非常简单:

async function sleep(millis) {
    return new Promise(resolve => setTimeout(resolve, millis));
}

您可以在我的另一个答案 here 中获得有关其工作原理的完整说明.

好的，回到其他功能。 request 库有一个支持 Promise 的版本，您可以将其与 async/await 一起使用。让我们看看 fetchPage() 是如何实现的:

async function fetchPage(url) {
    return await request({
        url: url,
        transform: (body) => cheerio.load(body)
    });
}

由于 request 正在返回一个 Promise，我们可以对其进行 await。我还借此机会使用了 transform 属性，它允许我们在解决 promise 之前转换响应体。我通过 Cheerio 传递它，就像你在代码中所做的那样。

最后，fetchUrls() 可以调用 fetchPage() 并对其进行处理以获取您的 URL 数组，然后再解析它的 Promise。完整代码如下:

const
    request = require("request-promise-native"),
    cheerio = require("cheerio");

const
    INITIAL_URL = "http://your-initial-url.com";

/**
 * Asynchronously fetches the page referred to by `url`.
 *
 * @param {String} url - the URL of the page to be fetched
 * @return {Promise} promise to a cheerio-processed page
 */
async function fetchPage(url) {
    return await request({
        url: url,
        transform: (body) => cheerio.load(body)
    });
}

/**
 * Your initial fetch which will bring the list of URLs your looking for.
 *
 * @param {String} initialUrl - the initial URL
 * @return {Promise<string[]>} an array of URL strings
 */
async function fetchUrls(initialUrl) {
    const $ = await fetchPage(initialUrl);
    // process $ here and get urls
    return ["http://foo.com", "http://bar.com"];
}

/**
 * Clever way to do asynchronous sleep. 
 * Check this: https://stackoverflow.com/a/46720712/778272
 *
 * @param {Number} millis - how long to sleep in milliseconds
 * @return {Promise<void>}
 */
async function sleep(millis) {
    return new Promise(resolve => setTimeout(resolve, millis));
}

async function run() {
    const urls = await fetchUrls(INITIAL_URL);
    for (const url of urls) {
        await sleep(10000);
        const $ = await fetchPage(url);
        // do stuff with cheerio-processed page
    }
}

run();

要将 request 与 Promise 一起使用，请按如下方式安装:

npm install request
npm install request-promise-native

然后在您的代码中添加 require("request-promise-native")，就像上面的示例一样。

关于javascript - 延迟 Node js中的每个循环迭代，异步，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30514584/