0

这感觉像是一个显而易见的问题，但让我感到困惑：我想要一个 Node 函数，它可以通过 URI 下载资源。我需要它适用于几种不同的内容类型，而用户无需指定它是哪种类型。

当您知道它将成为图像时，我知道如何通过管道request传输fs.createWriteStream，但当您已经从请求中调用回调时，我不知道如何处理它。这就是我所在的位置：

var request = require('request'),
    fs = require('graceful-fs');

function cacheURI(uri, cache_path, cb) {
    request(uri, function(err, resp, body) {
        var content_type = resp.headers['content-type'].toLowerCase().split("; ")[0],
            type = content_type.split("/")[0],
            sub_type = content_type.split("/")[1];

        if (sub_type == "json") {
            body = JSON.parse(body);
        }

        if (type == "image") {
            // this is where the trouble starts
            var ws = fs.createWriteStream(cache_path);
            ws.write(body);
            ws.on('close', function() {
                console.log('image done');
                console.log(resp.socket.bytesRead);
                ws.end();
                cb()
            });         
        } else {
            // this works fine for text resources
            fs.writeFile(cache_path, body, cb);     
        }


    });
}

这个对上一个问题的回答暗示了以下几点：

request.get({url: 'https://someurl/somefile.torrent', encoding: 'binary'}, function (err, response, body) {
  fs.writeFile("/tmp/test.torrent", body, 'binary', function(err) {
    if(err)
      console.log(err);
    else
      console.log("The file was saved!");
  }); 
});

request但是如果我还不知道我会得到什么类型的响应，我就不能传递“二进制” 。

更新

根据建议的答案，在事件处理程序中将“关闭”更改为“完成”确实会触发回调：

        if (opts.image) {
            var ws = fs.createWriteStream(opts.path);
            ws.on('finish', function() {
                console.log('image done');
                console.log(resp.socket.bytesRead);
            });
            //tried as buffer as well
            //ws.write(new Buffer(body));
            ws.write(body);
            ws.end();
        }

这确实写入了图像文件，但不正确：

在此处输入图像描述

4

1 回答 1

0

如此处建议，尝试使用finish事件（如果你有节点> = v0.10）

ws.on('finish', function() {
    console.log('image done');
    console.log(resp.socket.bytesRead);
    ws.end();
    cb()
});
于 2015-01-21T23:07:16.303 回答