var fs=require("fs")
|
var http = require('http');
|
var path = require('path');
|
|
function paserFileName(filename){
|
if(filename.length>50){
|
var dotIndex=filename.lastIndexOf(".");
|
var exName=filename.substr(dotIndex);
|
var fnlen=50-exName.length;
|
return filename.substr(0,fnlen)+exName;
|
}
|
else
|
return filename;
|
}
|
/**
|
*
|
* @param {*} fileDataInfo [{urlKey: "abc", urlValue: "空格 中文"}]
|
* @param {*} fileKeyValue [{urlKey: "file1", urlValue: "E:\\1.jpg"}]
|
* @param {*} req
|
*/
|
function postFile(fileDataInfo, fileKeyValue, req) {
|
var boundaryKey = Math.random().toString(16);
|
var enddata = '\r\n----' + boundaryKey + '--';
|
|
var dataLength = 0;
|
var dataArr = new Array();
|
for (var i = 0; i < fileDataInfo.length; i++) {
|
var dataInfo = "\r\n----" + boundaryKey + "\r\n" + "Content-Disposition: form-data; name=\"" + fileDataInfo[i].urlKey + "\"\r\n\r\n" + fileDataInfo[i].urlValue;
|
var dataBinary = new Buffer(dataInfo, "utf-8");
|
dataLength += dataBinary.length;
|
dataArr.push({
|
dataInfo: dataInfo
|
});
|
}
|
|
var files = new Array();
|
for (var i = 0; i < fileKeyValue.length; i++) {
|
|
var content = "\r\n----" + boundaryKey + "\r\n" + "Content-Type: application/octet-stream\r\n" + "Content-Disposition: form-data; name=\"" + fileKeyValue[i].urlKey + "\"; filename=\"" +paserFileName(path.basename(fileKeyValue[i].urlValue)) + "\"\r\n" + "Content-Transfer-Encoding: binary\r\n\r\n";
|
|
var contentBinary = new Buffer(content, 'utf-8'); //当编码为ascii时，中文会乱码。
|
files.push({
|
contentBinary: contentBinary,
|
filePath: fileKeyValue[i].urlValue
|
});
|
}
|
|
var contentLength = 0;
|
for (var i = 0; i < files.length; i++) {
|
var filePath = files[i].filePath;
|
if (fs.existsSync(filePath)) {
|
var stat = fs.statSync(filePath);
|
contentLength += stat.size;
|
} else {
|
contentLength += new Buffer("\r\n", 'utf-8').length;
|
}
|
contentLength += files[i].contentBinary.length;
|
}
|
|
req.setHeader('Content-Type', 'multipart/form-data; boundary=--' + boundaryKey);
|
req.setHeader('Content-Length', dataLength + contentLength + Buffer.byteLength(enddata));
|
|
// 将参数发出
|
for (var i = 0; i < dataArr.length; i++) {
|
req.write(dataArr[i].dataInfo)
|
//req.write('\r\n')
|
}
|
|
var fileindex = 0;
|
var doOneFile = function() {
|
req.write(files[fileindex].contentBinary);
|
var currentFilePath = files[fileindex].filePath;
|
if (fs.existsSync(currentFilePath)) {
|
var fileStream = fs.createReadStream(currentFilePath, {bufferSize: 4 * 1024});
|
fileStream.pipe(req, {end: false});
|
fileStream.on('end', function() {
|
fileindex++;
|
if (fileindex == files.length) {
|
req.end(enddata);
|
} else {
|
doOneFile();
|
}
|
});
|
} else {
|
req.write("\r\n");
|
fileindex++;
|
if (fileindex == files.length) {
|
req.end(enddata);
|
} else {
|
doOneFile();
|
}
|
}
|
};
|
if (fileindex == files.length) {
|
req.end(enddata);
|
} else {
|
doOneFile();
|
}
|
}
|
function postFiles(options,fileDataInfo,fileKeyValue,callBackFunc,errorCallBackFunc){
|
var req = http.request(options, function(res) {
|
|
res.on("data", function(chunk) {
|
// console.log("BODY:" + chunk);
|
if(callBackFunc){
|
callBackFunc(JSON.parse(chunk));
|
}
|
|
})
|
});
|
req.on('error', function(e) {
|
if(errorCallBackFunc){
|
errorCallBackFunc(e)
|
}
|
});
|
postFile(fileDataInfo,fileKeyValue,req);
|
}
|
exports.postFiles=postFiles;
|
|
|
// //测试用例
|
// //http://nodejs.org/api/http.html#http_http_request_options_callback
|
// var fileDataInfo = [
|
// {urlKey: "abc", urlValue: "空格 中文"},
|
// {urlKey: "def", urlValue: "asdfasfs123477"}
|
// ]
|
|
// var files = [
|
// {urlKey: "file1", urlValue: "E:\\1.jpg"},
|
// {urlKey: "file2", urlValue: "文件不存在"},
|
// {urlKey: "file3", urlValue: ""},
|
// {urlKey: "file4", urlValue: ""},
|
// {urlKey: "file5", urlValue: "E:\\Pro 中文 空格.mp3"},
|
// {urlKey: "file6", urlValue: "E:\\DFBF.jpg"},
|
// {urlKey: "file7", urlValue: ""}
|
// ]
|
|
// var options = {
|
// host: "localhost",
|
// port: "8908",
|
// method: "POST",
|
// path: "/Home/Upload"
|
// }
|
|
// var req = http.request(options, function(res) {
|
// console.log("RES:" + res);
|
// console.log('STATUS: ' + res.statusCode);
|
// console.log('HEADERS: ' + JSON.stringify(res.headers));
|
// //res.setEncoding("utf8");
|
// res.on("data", function(chunk) {
|
// console.log("BODY:" + chunk);
|
// })
|
// })
|
|
// req.on('error', function(e) {
|
// console.log('problem with request:' + e.message);
|
// console.log(e);
|
// });
|
// postFile(fileDataInfo, files, req);
|
// console.log("done");
|
