Node.js中的异步功能

Waggoner_Keith

我的Node.js API中有一个端点，该端点返回由Google-Search-Scrapper库提供的结果的JSON数组。

app.get('/google_image_search', (req, res) => {
    var options = {
        query: 'grenouille',
        age: 'y', // last 24 hours ([hdwmy]\d? as in google URL)
        limit: 10,
        params: {} // params will be copied as-is in the search URL query string
    };

    var results = [];
    scraper.search(options, function(err, url, meta) {
        sem.take(function() { 
            if(err) throw err;

            var result = {
                title: meta.title,
                meta: meta.meta,
                description: meta.desc
            }
            results.push(result);
            sem.leave();
        });
    })

    console.log(results);

    res.json({
        results
    });
})

在scraper.search函数完成后，我需要console.log（results）和res.json（{results}）发生。当前，它总是返回一个空数组。

为每个结果调用传递给scraper.search（）函数的函数。因此，如果有10个结果该函数运行10次，这就是为什么我要等到数组已满以发送响应。

我尝试在不同的地方使用信号灯和互斥锁，但是没有运气。任何建议表示赞赏。

这是通过使用LIMIT变量检查我的结果数组来解决的。在答案下面概述了标记为正确的内容。

感谢大家的投入。

那将是烧瓶

放置res.send在回调之外将导致类似于此问题的竞争状况。google-search-scraper库的一个缺点是它并非旨在收集结果。

这应该是固定的：

var LIMIT = 10;
var options = { limit: LIMIT, ... };

var results = [];
var errs = [];
var resultsCount = 0;

function resultsHandler() {
    if (errs.length) {
       // handle error
    } else
       res.json({ results });
}

scraper.search(options, function resultHandler(err, url, meta) {
    if (err)
        errs.push(err);
    else {
        var result = {
            title: meta.title,
            meta: meta.meta,
            description: meta.desc
        };

        results.push(result);
    });

    resultsCount++;

    if (resultsCount === LIMIT)
       resultsHandler();
});

如果search在某些情况下可能不调用回调，则此方法将无效。

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。