17

我正在尝试使用带有内置并发控制的蓝鸟地图功能。

我想检索一个名称列表，然后为每个名称发出一些 POST 请求。例如，我想为一周中的每一天请求每个名称。但是，我需要限制并发 POST 请求的数量，因为预期的服务器有速率限制。

function getNames() {
    //Open mongodb connection
    //Get collection and array of names
    //return array of names in a promise 
}

function createDatesArray() {
    //Create an array of rates
    //return array of dates in a promise
    //Ex. return Promise.resolve(datesArray);
}

getNames().map(function (name) {
    return createDatesArray().map(function (date) {
        return requestData(date, name);
    }, {concurrency: 5});
}).then(function () {
//do something
});

这是使用蓝鸟并发的正确方法吗？

文档链接在这里bluebird documentation。

4

1 回答 1

18

简短回答：是的，这会将请求数限制为 5。

警告：请记住，您可能仍然容易受到更多限制，例如 HTTP 客户端或您可能正在使用的任何其他池、模块和服务。

此外，Mongo 连接旨在用作持久连接，因此您可能应该只打开一个然后使用它，而不是每次打开和关闭一个。

如果createDatesArray不做任何异步操作，您不必 Promise.resolve 它，您可以使用mapasPromise.map(datesArray, function(date){ ... })等的静态变体。我也不会嵌套。假设createDatesArray确实是异步的：

Promise.join(getNames(), createDatesArray(), function(names, dates){
    var tasks = [];
    names.forEach(function(name ){ // create Cartesian product of names * dates
        dates.forEach(function(date){
             tasks.push(function(){ return requestData(name, date); });
        });
    });
    return Promise.map(tasks, function(job){ return job(); } , { concurrency: 5} );
}), then(function(results){
     // do whatever
});
于 2014-07-14T20:37:07.550 回答