Node做中转服务器，转发接口
2018-06-24 00:33:07来源：未知 阅读 ()
2018年04月11日，转发修改。支持文件下载。
返回值处理代码修改！所有返回值以文件流的方式接收，支持附件下载和普通数据。你的框架要是可以直接访问访问文件服务器，那就直连了，要是像我一样，文件服务器在内网，只有前端服务器开了内网，那你就得和我一样，做文件下载转发，欢迎您，提供更好方案！
1 var body = ''; 2 var req = http.request(opt, function (res) { 3 res.setEncoding('binary'); //二进制binary 4 res.on('data', function (data) { 5 body += data; 6 }).on('end', function () { 7 response.writeHead(200, res.headers); 8 response.write(body, "binary"); 9 response.end(); 10 }); 11 }).on('error', function (e) { 12 response.end('内部错误，请联系管理员！MSG:' + e); 13 console.log("error: " + e.message); 14 })
查询各种资料，和整理网上一哥们不完整的接口。做成，可以使用的转发服务！
由于项目在做前后端分离，牵扯跨域和夸协议问题，临时抱佛脚，选择用nodejs做中转，我想应该好多人都用它。但是做普通的表单转发没啥问题，当处理附件上传转发时，各种蛋疼，已解决！
1.项目比较特殊，后台拥有两个平台，一个java一个donet，比较鸡肋，具体什么原因就不解释了。
2.刚开始没有转发文件的操作，就做的很简单，用户传过来啥就，拦截到，进行转发，一切都很ok！
3.当遇到文件转发时，就很麻烦。我的思路，将用户上传的文件存到node服务器。使用formidable 。
通过npm安装：
npm install formidable@latest
使用它进行文件转存，保存到临时目录得到文件信息。
再通过文件包重组。进行上传。注意此处上传必须遵循w3c上传文件表单标准，具体自己查资料。
其实思路很简单，但是实际操作起来还是挺麻烦，我中间也趟了好多坑，也是自己node不成熟，毕竟只是用来做中转！
直接上代码吧：看代码还是清晰：
server.js,用于启动服务并转发。
1 var http = require("http"); 2 var url = require("url"); 3 var fs = require('fs'); 4 const querystring = require("querystring"); 5 var path = require('path'); 6 var formidable = require('formidable'), 7 os = require('os'), 8 util = require('util'); 9 10 var config = require('./config').types; // 11 12 var netServerUrlFlag = require('./config').netServerUrlFlag; 13 var netServerhost = require('./config').netServerhost; 14 var netServerport = require('./config').netServerport; 15 16 var javaServerUrlFlag = require('./config').javaServerUrlFlag; 17 var javaServerhost = require('./config').javaServerhost; 18 var javaServerport = require('./config').javaServerport; 19 20 var fileServerUrlFlag = require('./config').fileServerUrlFlag; 21 22 var webapp = require('./config').webapp; 23 var PORT = require('./config').webport; 24 /** 25 * 上传文件 26 * @param files 经过formidable处理过的文件 27 * @param req httpRequest对象 28 * @param postData 额外提交的数据 29 */ 30 function uploadFile(files, req, postData) { 31 var boundaryKey = Math.random().toString(16); 32 var endData = '\r\n----' + boundaryKey + '--'; 33 var filesLength = 0, content; 34 35 // 初始数据，把post过来的数据都携带上去 36 content = (function (obj) { 37 var rslt = []; 38 Object.keys(obj).forEach(function (key) { 39 arr = ['\r\n----' + boundaryKey + '\r\n']; 40 arr.push('Content-Disposition: form-data; name="' + obj[key][0] + '"\r\n\r\n'); 41 arr.push(obj[key][1]); 42 rslt.push(arr.join('')); 43 }); 44 return rslt.join(''); 45 })(postData); 46 47 // 组装数据 48 Object.keys(files).forEach(function (key) { 49 if (!files.hasOwnProperty(key)) { 50 delete files.key; 51 return; 52 } 53 content += '\r\n----' + boundaryKey + '\r\n' + 54 'Content-Type: application/octet-stream\r\n' + 55 'Content-Disposition: form-data; name="' + files[key][0] + '"; ' + 56 'filename="' + files[key][1].name + '"; \r\n' + 57 'Content-Transfer-Encoding: binary\r\n\r\n'; 58 files[key].contentBinary = new Buffer(content, 'utf-8');; 59 filesLength += files[key].contentBinary.length + fs.statSync(files[key][1].path).size; 60 }); 61 req.setHeader('Content-Type', 'multipart/form-data; boundary=--' + boundaryKey); 62 req.setHeader('Content-Length', filesLength + Buffer.byteLength(endData)); 63 64 // 执行上传 65 var allFiles = Object.keys(files); 66 var fileNum = allFiles.length; 67 var uploadedCount = 0; 68 allFiles.forEach(function (key) { 69 req.write(files[key].contentBinary); 70 console.log("files[key].path:" + files[key][1].path); 71 var fileStream = fs.createReadStream(files[key][1].path, { bufferSize: 4 * 1024 }); 72 fileStream.on('end', function () { 73 // 上传成功一个文件之后，把临时文件删了 74 fs.unlink(files[key][1].path); 75 uploadedCount++; 76 if (uploadedCount == fileNum) { 77 // 如果已经是最后一个文件，那就正常结束 78 req.end(endData); 79 } 80 }); 81 fileStream.pipe(req, { end: false }); 82 }); 83 } 84 var server = http.createServer(function (request, response) { 85 var clientUrl = request.url; 86 var url_parts = url.parse(clientUrl); //解析路径 87 var pathname = url_parts.pathname; 88 89 var sreq = request; 90 var sres = response; 91 // .net 转发请求 92 if (pathname.match(netServerUrlFlag) != null) { 93 var clientUrl2 = clientUrl.replace("/" + netServerUrlFlag, ''); 94 console.log(".net转发请求......" + clientUrl2); 95 var pramsJson = ''; 96 sreq.on("data", function (data) { 97 pramsJson += data; 98 }).on("end", function () { 99 var contenttype = request.headers['content-type']; 100 if (contenttype == undefined || contenttype == null || contenttype == '') { 101 var opt = { 102 host: netServerhost, //跨域访问的主机ip 103 port: netServerport, 104 path: clientUrl2, 105 method: request.method, 106 headers: { 107 'Content-Length': Buffer.byteLength(pramsJson) 108 } 109 } 110 } else { 111 var opt = { 112 host: netServerhost, //跨域访问的主机ip 113 port: netServerport, 114 path: clientUrl2, 115 method: request.method, 116 headers: { 117 'Content-Type': request.headers['content-type'], 118 'Content-Length': Buffer.byteLength(pramsJson) 119 } 120 } 121 } 122 console.log('method', opt.method); 123 124 var body = ''; 125 var req = http.request(opt, function (res) { 126 res.on('data', function (data) { 127 body += data; 128 }).on('end', function () { 129 response.write(body); 130 response.end(); 131 }); 132 }).on('error', function (e) { 133 response.end('内部错误，请联系管理员！MSG:' + e); 134 console.log("error: " + e.message); 135 }) 136 req.write(pramsJson); 137 req.end(); 138 }) 139 140 } else 141 // java 转发请求 142 if (pathname.match(javaServerUrlFlag) != null) { 143 response.setHeader("Content-type", "text/plain;charset=UTF-8"); 144 145 var clientUrl2 = clientUrl.replace("/" + javaServerUrlFlag, ''); 146 console.log(".java转发请求......http://" + javaServerhost + ":" + javaServerport + "" + clientUrl2); 147 var prams = ''; 148 sreq.on("data", function (data) { 149 prams += data; 150 }).on("end", function () { 151 console.log("client pramsJson>>>>>" + prams); 152 const postData = prams; 153 console.log("client pramsJson>>>>>" + postData); 154 var contenttype = request.headers['content-type']; 155 if (contenttype == undefined || contenttype == null || contenttype == '') { 156 var opt = { 157 host: javaServerhost, //跨域访问的主机ip 158 port: javaServerport, 159 path: "/hrrp" + clientUrl2, 160 method: request.method, 161 headers: { 162 'Content-Length': Buffer.byteLength(postData) 163 } 164 } 165 } else { 166 var opt = { 167 host: javaServerhost, //跨域访问的主机ip 168 port: javaServerport, 169 path: "/hrrp" + clientUrl2, 170 method: request.method, 171 headers: { 172 'Content-Type': request.headers['content-type'], 173 'Content-Length': Buffer.byteLength(postData) 174 } 175 } 176 } 177 var body = ''; 178 179 console.log('method', opt.method); 180 var req = http.request(opt, function (res) { 181 //console.log("response: " + res.statusCode); 182 res.on('data', function (data) { 183 body += data; 184 }).on('end', function () { 185 response.write(body); 186 response.end(); 187 //console.log("end:>>>>>>>" + body); 188 }); 189 }).on('error', function (e) { 190 response.end('内部错误，请联系管理员！MSG:' + e); 191 console.log("error: " + e.message); 192 }) 193 194 req.write(postData); 195 req.end(); 196 197 198 }) 199 } else if (pathname.match(fileServerUrlFlag) != null) { 200 //文件拦截保存到本地 201 var form = new formidable.IncomingForm(), 202 files = [], 203 fields = []; 204 form.uploadDir = os.tmpdir(); 205 form.on('field', function (field, value) { 206 console.log(field, value); 207 fields.push([field, value]); 208 }).on('file', function (field, file) { 209 console.log(field, file); 210 files.push([field, file]); 211 }).on('end', function () { 212 // 213 var clientUrl2 = clientUrl.replace("/" + fileServerUrlFlag, ''); 214 var opt = { 215 host: netServerhost, //跨域访问的主机ip 216 port: netServerport, 217 path: clientUrl2, 218 method: request.method 219 } 220 var body = ''; 221 var req = http.request(opt, function (res) { 222 res.on('data', function (data) { 223 body += data; 224 }).on('end', function () { 225 response.write(body); 226 response.end(); 227 }); 228 }).on('error', function (e) { 229 response.end('内部错误，请联系管理员！MSG:' + e); 230 console.log("error: " + e.message); 231 }) 232 //文件上传 233 uploadFile(files, req, fields); 234 }); 235 form.parse(sreq); 236 } 237 else { 238 var realPath = path.join(webapp, pathname); //这里设置自己的文件名称; 239 var ext = path.extname(realPath); 240 ext = ext ? ext.slice(1) : 'unknown'; 241 fs.exists(realPath, function (exists) { 242 //console.log("file is exists："+exists+" file path: " + realPath + ""); 243 if (!exists) { 244 response.writeHead(404, { 245 'Content-Type': 'text/plain' 246 }); 247 248 response.write("This request URL " + pathname + " was not found on this server."); 249 response.end(); 250 } else { 251 fs.readFile(realPath, "binary", function (err, file) { 252 if (err) { 253 response.writeHead(500, { 254 'Content-Type': 'text/plain' 255 }); 256 //response.end(err); 257 response.end("内部错误，请联系管理员"); 258 } else { 259 var contentType = config[ext] || "text/plain"; 260 response.writeHead(200, { 261 'Content-Type': contentType 262 }); 263 response.write(file, "binary"); 264 response.end(); 265 } 266 }); 267 } 268 }); 269 270 } 271 }); 272 server.listen(PORT); 273 console.log("Server runing at port: " + PORT + ".");
config.js，用于配置。
1 exports.types = { 2 "css": "text/css", 3 "gif": "image/gif", 4 "html": "text/html", 5 "htm": "text/html", 6 "ico": "image/x-icon", 7 "jpeg": "image/jpeg", 8 "jpg": "image/jpeg", 9 "js": "text/javascript", 10 "json": "application/json", 11 "pdf": "application/pdf", 12 "png": "image/png", 13 "svg": "image/svg+xml", 14 "swf": "application/x-shockwave-flash", 15 "tiff": "image/tiff", 16 "txt": "text/plain", 17 "wav": "audio/x-wav", 18 "wma": "audio/x-ms-wma", 19 "wmv": "video/x-ms-wmv", 20 "xml": "text/xml" 21 }; 22 23 exports.netServerUrlFlag = "NETSERVER"; 24 exports.netServerhost = ""; 25 exports.netServerport = ""; 26 27 exports.javaServerUrlFlag = "JAVASERVER"; 28 exports.javaServerhost = ""; //转发的地址 29 exports.javaServerport = "";//转发的端口 30 31 exports.fileServerUrlFlag="FileUpload"; 32 exports.webapp = "public";//项目目录 33 34 exports.webport = "82"; //项目启动端口
标签：
版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有
上一篇：Function 类型
下一篇：节点的创建，删除，复制
相关文章
- nodejs中如何使用async模块 2020-02-22
- nodejs的express自动生成项目框架的方法 2020-02-20
- Node.js中环境变量process.env的一些事详解 2020-01-17
- 详解node.js进行web开发的操作方法 2019-12-14
- 分享nodejs分页类代码 2019-12-02
IDC资讯： 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营： 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧： 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash
热门词条
最新资讯
热门关注
热门标签