async.eachOfLimit不限制我的http请求数为10。
async.eachOfLimit不限制我的http请求数为10。
提问于 2019-02-16 14:25:03
const unirest = require('unirest');
const async = require('async');
let count = 0;
let ids = [];
(async () => {
for (let index = 1; index <= 20; index++) {
ids.push(index);
}
async.eachOfLimit(ids, 10, makeRequest, function (err) {
if (err) throw err;
});
})();
async function makeRequest(index, callback) {
console.log(index);
await unirest.get('https://api.ipify.org?format=json')
.headers({ 'Content-Type': 'application/json' })
.end(async (response) => {
console.log(response.body);
});
}我使用async.eachOfLimit将请求数量限制为10，但当我运行他从1到20打印的代码时，它不起作用，我也试图调用回调，但我得到回调不是一个函数，如何解决它，并将请求限制为10个并发，谢谢
回答 1
Stack Overflow用户
回答已采纳
发布于 2019-02-16 14:44:42
您将异步/等待编码与回调混合在一起。当您使用async.js库时，makeRequest函数必须是：
- 调用回调的正常函数。
- 一个标记为‘异步’的函数，它返回一个承诺。
如果函数被标记为‘异步’，async.js将不会将callback参数传递给它。相反，它只是等待一个承诺来解决。
在您的代码中，实际上没有什么必须是“异步”的。你可以到处都用回电话。
下面是一个工作片段：
const unirest = require('unirest');
const async = require('async');
let count = 0;
let ids = [];
for (let index = 1; index <= 20; index++) {
ids.push(index);
}
async.eachOfLimit(ids, 10, makeRequest, function (err) {
if (err) throw err;
});
function makeRequest(item, index, callback) {
console.log(item);
unirest.get('https://api.ipify.org?format=json')
.headers({ 'Content-Type': 'application/json' })
.end(async (response) => {
console.log(response.body);
callback();
});
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/54724064
复制相关文章
相似问题
腾讯云开发者
