2014-05-09 69 views
0

我的应用程序旨在扫描代理列表。 当我有一个死代理错误事件是调用,但回调或结束事件是永远不会调用,为什么?错误事件后继续Node.js Webkit

var file = e.dataTransfer.files[i].path; 
    content = fs.readFileSync(file, "UTF-8"); 
    var lines = content.split("\n"); 
    var nb = 0; 
    async.each(lines, function(line, callback) { 

     var arr = line.split(":"); 
     http.get({host: arr[0], port: arr[1], path: "http://www.google.fr", agent: false}, function(res, req) { 
      if(res.statusCode == 200){ 
       el.className = ''; 
       el.innerHTML = arr[0] + ':' + arr[1] + '\n'; 
       nb = nb+1; 
      } 
      callback(); 
     }).on('error', function(e) { 
      console.error(arr[0] + ':' + arr[1]); 
     }).on('end', function(e) { 
      console.error('End event nerver load...'); 
     }); 
    },function(){ 
     el.className = ''; 
     el.innerHTML = 'Scan terminé. ' + nb + ' Proxy fonctionnels'; 
    }); 

回答

2

它看起来像你使用的是异步库。

您传递给async.each的迭代器要求您调用回调,而不管是否存在错误。如果您不调用回调,异步会认为该操作仍在运行,并且将永远等待。

当您遇到错误时,您应该调用回调并将错误作为第一个参数传递。

所以这里是我的意思的一个例子。我已将callback(e);添加到您的错误事件处理程序中。

}).on('error', function(e) { 
     console.error(arr[0] + ':' + arr[1]); 
     callback(e); 
    }).on('end', function(e) { 
+0

谢谢,但如果我打电话回调每个循环将停止?我想继续迭代,即使我得到一个错误。我想在停止之前解析每个文件的ip – Pixel

+0

这就是async.each的工作原理。 – Mikuso

+0

如果您想继续迭代而不终止错误,只需调用没有错误的回调。 '回调();' – Mikuso