HTTP 从不同站点获取文件并使用 Express 返回以供下载

Question

我正在尝试在快速 HTTP 获取请求后从我的 Node 应用程序从另一个站点下载文件，然后返回文件以供下载。我尝试了多种获取文件的方法，使用管道、blob 等，但我在黑暗中掌握。该代码可能会让您更深入地了解我想要实现的目标：

var router = require('express').Router();
var fs = require('fs');
var http = require('http');

router.get('/download/:file', function (req, res, next) {
  http.get('http://anothersite/' + req.params.file, function(response) {
    res.setHeader('Content-disposition', 'attachment; filename=' + req.params.file);
    res.setHeader('Content-type', 'application/octet-stream');
    res.download(fs.createWriteStream(req.params.file).pipe(response));
  });
});

这给了我一个错误“无法管道。不可读”。该文件本身不是常规文件格式（它是来自我们定制软件的文件，具有自己的扩展名）。

我错过了什么？

Answer 1

你需要在这里使用可读流，而不是可写

Express res 对象派生自节点的http.ServerResponse，它本身实现了节点的WritableStream 接口。请参阅文档 here 和 here。

既然如此，我认为您可以直接使用response 参数传递给您的回调，因为那已经是ReadableStream（参见here）。尝试使用这样的可读流：

router.get('/download/:file', function (req, res, next) {
  http.get('http://anothersite/' + req.params.file, function(response) {
    res.setHeader('Content-disposition', 'attachment; filename=' + req.params.file);
    res.setHeader('Content-type', 'application/octet-stream');
    response.pipe(res);  //  <-- change here
  });
});

此代码正在运行，节点 v5.0.0 和最新的 chrome：

const express = require('express');
const app = express();
const http = require('http');

app.get('/', (req, res) => {
  http.get('http://www.fillmurray.com/200/300', (response) => {
    res.setHeader('Content-disposition', 'attachment; filename=' + 'hello.jpg');
    res.setHeader('Content-type', 'application/octet-stream');
    response.pipe(res)
  });
});

app.listen(3001, () => console.log(('listening :)')))

Answer 2

您可以将请求库用作： request('http://anothersite/').pipe(fs.createWriteStream('filename.extension'))

更新：

如果您愿意通过 http 执行此操作，您可以创建一个写入流，如下所示。成功保存文件后，我认为您可以正确执行res.download()。

var http = require('http')

http.get('http://www.google.com/images/branding/googlelogo/1x/googlelogo_color_272x92dp.png').on('response', function (response) {
    var writeStream = fs.createWriteStream('output.png');

    response.pipe(writeStream);

    response.on('end', function () {
        console.log('stream completed!')
    });

    // This is here incase any errors occur
    writeStream.on('error', function (err) {
        console.log(err);
    });

});