javascript – Node.js：执行多个异步操作的最佳方法,然后执行其他操作？

在下面的代码中,我试图一次性发出多个(大约10个)HTTP请求和RSS解析.

我在一个URI数组上使用标准的forEach构造,我需要访问并解析结果.

码：

var articles;

FeedsToFetch.forEach(function (FeedUri)
{   
        Feed(FeedUri,function(err,FeedArticles) 
        {
            if (err)
            {
                throw err;
            }
            else
            {
                articles = articles.concat(FeedArticles);
            }
        });
 });

 // Code I want to run once all FeedUris have been visited

我明白,当我应该使用回调时调用一个函数.但是,我能想到在这个例子中使用回调的唯一方法是调用一个函数,该函数计算它被调用的次数,并且仅在调用与FeedToFetch.length相同的次数时才继续调用,这看起来像hacky .

所以我的问题是,在node.js中处理这种情况的最佳方法是什么.

优选地,没有任何形式的阻塞！ (我仍然希望速度超快).这是承诺还是其他什么？

谢谢,
丹尼

解决方法

无需解决方案

Promises to be included in next JavaScript version

流行的Promise库为这个确切的用例提供了一个.all()方法(等待一堆异步调用完成,然后做其他事情).这是您的场景的完美搭配

Bluebird还有.map(),它可以获取一组值并使用它来启动Promise链.

以下是使用Bluebird .map()的示例：

var Promise = require('bluebird');
var request = Promise.promisifyAll(require('request'));

function processAllFeeds(FeedsToFetch) {    
    return Promise.map(FeedsToFetch,function(Feed){ 
        // I renamed your 'Feed' fn to 'processFeed'
        return processFeed(Feed) 
    })
    .then(function(articles){
        // 'articles' is Now an array w/ results of all 'processFeed' calls
        // do something with all the results...
    })
    .catch(function(e){
        // Feed server was down,etc
    })
}

function processFeed(Feed) { 
    // use the promisified version of 'get'
    return request.getAsync(Feed.url)... 
}

另请注意,您不需要在此处使用闭包来累积结果.

Bluebird API Docs也写得很好,有很多例子,所以它更容易上手.

一旦我学会了Promise模式,它就让生活变得如此简单.我不能推荐它.

此外,这里是a great article关于使用promises,异步模块和其他处理异步函数的不同方法

希望这可以帮助！