6

我正在用 node.js 和请求模块编写一个下载器。使用我正在做的流语法

var r = request(url).pipe(fs.createWriteStream(targetPath));
r.on('error', function(err) { console.log(err); });
r.on('finish', cb);

下载文件,保存并调用回调。然而,在几乎 50% 的情况下,文件要么是空的,要么根本没有创建。error不发出任何事件。finish即使文件尚未(完全)写入,似乎也触发了事件。

上下文:整个事情都包含在async.each调用中。

有什么线索吗?谢谢!

4

1 回答 1

12

您需要在访问之前关闭该文件:

var file = fs.createWriteStream(targetPath);
var r = request(url).pipe(file);
r.on('error', function(err) { console.log(err); });
r.on('finish', function() { file.close(cb) });

顺便说一句,如果 url 回复任何 http 错误(例如未找到 404),则不会触发 'error' 事件,因此您应该单独检查:

function handleFailure(err) { console.log(err); };

var file = fs.createWriteStream(targetPath);
request(url, function(error, response) {
    if (response.statusCode != 200) {
        console.log("oops, got a " + response.statusCode);
        return
    }
    // close is async, and you have to wait until close completes otherwise
    // you'll (very rarely) not be able to access the file in the callback.
    file.on('finish', function() { file.close(cb) });

    response.pipe(file).on('error', handleFailure)
    file.on('error', handleFailure)
}).on('error', handleFailure);
于 2014-03-28T08:23:04.067 回答