writeStream结束之前的节点进程退出

Question

我有一个nodejs程序从服务器下载一堆文件。问题是该过程在文件实际下载之前退出，所以我得到一个损坏的文件。

for(var i = 0; i < items.length; i++){ 
    var file = fs.createWriteStream(items[i].filename); 
    var request = http.get(items[i].url, function (response) { 
     console.log('got:', i); 
     response.pipe(file); 
    }); 
    request.on('end', function() { 
     console.log('done with ' + filePath); 
    }); 
} 

但是，当最后一个请求收到其响应时，进程退出。我从来没有得到“完成”日志。

任何人有想法？

谢谢！

Answer 1

您正在错误地处理异步性。

尝试使用所谓的async库，并使用它像这样

async.eachSeries(items, function (item, callback) { 
    var file = fs.createWriteStream(item.filename); 
    var request = http.get(item.url, function (response) { 
     response.pipe(file); 
    }); 
    request.on('end', function() { 
     console.log('done with ' + filePath); 
     callback(null); 
    }); 
}, function (err) { 
    console.log('All done!'); 
});