0

我正在努力处理 Node.js 中的异步事件。

我的应用程序正在执行第一个 HTTP GET 请求，然后根据在响应正文中找到的一些信息，它循环了一定次数。

在每次迭代中，它调用一个函数，该函数发送其他 HTTP GET 请求并返回推送到元素数组中的结果。

我的问题是，当所有 http 请求完成后，我想要console.log()元素数组。这是我的代码：

http.get('mysite.com', function(res) {
    var body = '';
    res.on('data', function(chunk) {
        body += chunk;
    });
    res.on('end', function() {
        var last = 5,
            elements = [];
        for(var i=0; i < last; i++) {
            elements.push(myRequest(i));
        }
        console.log(elements);
        // Do some stuff with the elements array after it has been populated
    });
}).on('error', function(error) {
    console.log(error);
});

var myRequest = function(i) {
    http.get('mysite.com/page' + i, function(res) {
        var body = '';
        res.on('data', function(chunk) {
            body += chunk;
        });
        res.on('end', function() {
            // Do parsing here
            return parsed;
        });
    }).on('error', function(error) {
        console.log(error);
    });
};

我考虑过使用异步模块，但我不确定如何在这个用例中使用它。

提前致谢 ！

4

1 回答 1

2

我会使用异步库，也许会使用队列。但是如果你想手工做，没有测试过下面的任何东西，也不确定这是最干净的方法，但它可能会给你一些想法。

将回调传递给您的请求函数：

var myRequest = function(i, cb){
   ...
   res.on('end', function(){
      cb(parsed);
   });
}

及以上 onEnd-call 看起来更像这样：

var last = 5, elements = [];

var rep = function(i){
  if( i < last ){
     myRequest(i, function( result ){
        elements.push(result);              
        rep(i+1);
     });
  } else {
    console.log(elements);
    // Do some stuff with the elements array after it has been populated
  }
}

res.on('end', function() {
   rep(0);
});

使用 async 会更好看。不过现在得跑了……

于 2012-12-23T11:47:23.270 回答