我正在使用node.js编写一个http服务器,但在将请求正文作为可读流隔离时遇到了问题。这是我的代码基本示例:
var http = require('http')
, fs = require('fs');
http.createServer(function(req, res) {
if ( req.method.toLowerCase() == 'post') {
req.pipe(fs.createWriteStream('out.txt'));
req.on('end', function() {
res.writeHead(200, {'content-type': 'text/plain'})
res.write('Upload Complete!\n');
res.end();
});
}
}).listen(8182);
console.log('listening on port 8182');
根据Node的文档,请求参数是http.IncomingObject的实例,该实例实现了Node的可读流接口。上述代码中仅使用stream.pipe()存在问题,即可读流包括请求头的纯文本以及请求体。是否有办法仅将请求体作为可读流进行隔离?
我知道有一些针对文件上传的框架,例如formidable。我的最终目标不是创建一个上传服务器,而是充当代理并将请求体流式传输到另一个Web服务。
提前致谢。
编辑>>使用busboy处理"Content-type: multipart/form-data"的工作服务器
var http = require('http')
, fs = require('fs')
, Busboy = require('busboy');
http.createServer(function(req, res) {
if ( req.method.toLowerCase() == 'post') {
var busboy = new Busboy({headers: req.headers});
busboy.on('file', function(fieldname, file, filename, encoding, mimetype) {
file.pipe(fs.createWriteStream('out.txt'));
});
req.pipe(busboy);
req.on('end', function() {
res.writeHead(200, 'Content-type: text/plain');
res.write('Upload Complete!\n');
res.end();
});
}
}).listen(8182);
console.log('listening on port 8182');