用节点将上传的文件通过管道传输到远程服务器（最好使用相同的文件名）

公西姚石

2023-03-14

问题内容：

我想在我的app.js服务器中上传文件，该文件应将该文件通过管道传送到跨域服务器，例如我的upload.js服务器。

完整代码可在以下链接下找到

upload.js服务器正在运行。我的问题是app.js服务器。请求似乎能够流式传输文件（https://github.com/request/request#streaming）。但是我没有使它工作。我总是在我的app.js中收到[错误：无效的协议]。

这至少是这一行：

fs.createReadStream(file.path).pipe(request.post('localhost:4000/upload'))

我将post更改为put，并在我的upload.js中将post方法也更改为put，但这会导致相同的错误。

_我的目标是将文件从html页面上传到localhost：3000 / upload，该文件通过管道将文件传输到localhost：4000 /
upload（最好使用相同的文件名）。_但是我没有使它工作）。

app.js：

var express = require('express')
    , multiparty = require('multiparty')
    , request = require('request')
    , fs = require('fs')
    , util = require('util')
    , http = require('http');

var app = express();
app.use('/static', express.static('static'));

process.on('uncaughtException', function (err) {
    console.log(err);
});

app.get('/', function (req, res) {
    res.redirect('static/index.html');
});

app.post('/upload', function(req, res, next){

    //https://github.com/request/request#streaming

    var form = new multiparty.Form();

    form.parse(req, function(err, fields, files) {
        res.writeHead(200, {'content-type': 'text/plain'});
        res.write('received upload:\n\n');
        res.end(util.inspect({fields: fields, files: files}));
    });
    form.on('file', function(name,file) {

        //stream it to localhost:4000 with same name
        fs.createReadStream(file.path).pipe(request.post('localhost:4000/upload'))

        console.log(file.path);
    });

});

var server = app.listen(3000, '0.0.0.0' ,function () {
    var host = server.address().address;
    var port = server.address().port;

    console.log('Example app listening at http://%s:%s', host, port);
});

index.html：

<!DOCTYPE html>
<html>
<head lang="en">
    <meta charset="UTF-8">
    <title>Upload</title>
</head>
<body>
  <h2>Upload</h2>
  <form method="post" action="/upload" enctype="multipart/form-data">
    <input type="file" id="file" name="file" />
    <button>upload</button>
  </form>
</body>
</html>

upload.js：

var express = require('express')
    , multiparty = require('multiparty')
    , cors = require('cors')
    , util = require('util')
    , app = express();

app.use(cors());
process.on('uncaughtException', function (err) {
    console.log(err);
});

app.get('/', cors(), function(req, res, next){
    res.json({msg: 'This is CORS-enabled for all origins!'});
});

app.post('/upload', cors(), function(req, res, next){
    var form = new multiparty.Form();

    form.parse(req, function(err, fields, files) {
        res.writeHead(200, {'content-type': 'text/plain'});
        res.write('received upload:\n\n');
        res.end(util.inspect({fields: fields, files: files}));
    });
    form.on('file', function(name,file) {
        console.log(file);
        console.log(name);
    });

});

app.listen(4000, function(){
    console.log('CORS-enabled web server listening on port 4000');
});

问题答案：

更新

我相信您在网址中缺少该协议。如果将http协议添加到url ，它应该可以工作：

fs.createReadStream(file.path).pipe(request.post('http://localhost:4000/upload'))

使上传工作

当您将文件内容通过管道传递到upload.js中的POST函数时，多部分表单数据将丢失。您需要创建一个新的POST请求并传递原始文件内容。

在中执行以下操作app.js：

 form.on('file', function(name, file) {

    var formData = {
      file: {
        value:  fs.createReadStream(file.path),
        options: {
          filename: file.originalFilename
        }
      }
    };

    // Post the file to the upload server
    request.post({url: 'http://localhost:4000/upload', formData: formData});
}

这还将传递原始文件名。有关更多信息，请参见：https : //github.com/request/request#multipartform-
data-multipart-form-uploads

用节点将上传的文件通过管道传输到远程服务器（最好使用相同的文件名）

相关阅读

相关文章

相关问答

相关工具

相关文档