pipe道stream请求发布不起作用

我已经阅读请求的文档页面 ，可以将文件stream式传输到PUT或POST请求，如下所示：

fs.createReadStream('file.json').pipe(request.put('http://example.com/obj.json')); request.get('http://google.com/img.png').pipe(request.put('http://example.com/img.png')); 

但它似乎不起作用。 我试图设置一个本地服务器上传文件使用不同的库。

快车打杂：

 var express = require('express'); var app = express(); var fs = require('fs'); var bb = require('express-busboy'); var app = express(); bb.extend(app, { upload: true, path: './img/', allowedPath: /./ }); app.post('/upload', function(req, res) { console.log(req.files); }); var server = app.listen(process.env.PORT, function() { console.log('Listening on port %d', server.address().port); }); 

和强大：

 var express = require('express'); var app = express(); var path = require('path'); var fs = require('fs'); var formidable = require('formidable'); app.post('/upload', function(req, res){ // create an incoming form object var form = new formidable.IncomingForm(); // specify that we want to allow the user to upload multiple files in a single request form.multiples = true; // store all uploads in the /uploads directory form.uploadDir = path.join(__dirname, '/img'); // every time a file has been uploaded successfully, // rename it to it's orignal name form.on('file', function(field, file) { fs.rename(file.path, path.join(form.uploadDir, file.name)); }); // log any errors that occur form.on('error', function(err) { console.log('An error has occured: \n' + err); }); // once all the files have been uploaded, send a response to the client form.on('end', function() { res.end('success'); }); // parse the incoming request containing the form data form.parse(req); }); var server = app.listen(process.env.PORT, function() { console.log('Listening on port %d', server.address().port); }); 

当我提出这样的请求时，两者都可以正常工作：

 var request = require('request'); var fs = require('fs'); var formData = { filename: { value: fs.createReadStream('ice.jpg'), options: { filename: 'ice.jpg', contentType: ' image/jpeg' }} }; request.post({url: 'https://myserver.com/upload', formData: formData}); 

或者从命令行：

 curl -i -X POST -H "Content-Type: multipart/form-data" -F "data=@ice.jpg" https://myserver.com/upload 

但是当我试图这样做时，他们都不工作：

 fs.createReadStream('ice.jpg').pipe(request.post('https://myserver.com/upload')); 

难道我做错了什么？ 有没有办法让最后一行工作？

Answer 1

好。 我正在回答这个问题，以防有人遇到类似的问题。

curl和request.post与formData选项都发送一个“Content-Type：multipart / form-data”标题的post请求。 快递公司 ， 强大的和多function的图书馆被用来parsing这些数据。

这一行：

 fs.createReadStream('ice.jpg').pipe(request.post('https://myserver.com/upload')); 

用“Content-Type：image / jpeg”和“Transfer-Encoding：chunked”标题发送请求。 这里不需要parsing多部分表单数据。

服务器上的以下代码将在这种情况下工作：

 var http = require('http'); var fs = require('fs'); var server = http.createServer(function(req, res){ console.log(req.headers); var body = []; req .on('data', chunk => { body.push(chunk); console.log('Chunk ', chunk); }) .on('end', () => { body = Buffer.concat(body); fs.writeFileSync('newfile.jpg', body, null); }); res.write("OK\n"); res.end(); });