Node agit comme un serveur de transit et transmet l'interface

Node agit comme un serveur de transit et transmet l'interface - Shi Haibin

一个新手

Libérer： 2017-10-19 09:46:05

original

1866 Les gens l'ont consulté

Interrogez diverses informations et faites le tri dans l'interface incomplète d'un copain sur Internet. C'est fait, vous pouvez utiliser le service de réexpédition !

Étant donné que le projet sépare le front-end et le back-end, impliquant des problèmes inter-domaines et de protocole, j'ai été temporairement dépassé et j'ai choisi d'utiliser nodejs pour le transit, je pense que beaucoup de gens devraient l'utiliser. Mais il n'y a aucun problème lors du transfert de formulaires ordinaires. Lors du téléchargement et du transfert de pièces jointes, toutes sortes de problèmes ont été résolus !

1. Le projet est assez particulier. Il a deux plateformes en arrière-plan, l'une est java et l'autre est donet, ce qui est assez inutile, je n'expliquerai pas les raisons précises.

2. Lors du transfert de nœud, il n'y a pas d'opération de transfert de fichiers au début, c'est donc très simple. L'utilisateur peut intercepter tout ce qui est transmis et le transférer, et tout va bien !

3. Le transfert de fichiers est très gênant. Mon idée est de sauvegarder les fichiers téléchargés par les utilisateurs sur le serveur de nœuds. Utilisez formidable .

Installer via npm :

npm install formidable@latest

Copier après la connexion

Utilisez-le pour transférer des fichiers et les enregistrer dans un répertoire temporaire pour obtenir des informations sur les fichiers.

Réorganiser via un package de fichiers. à télécharger. Notez que le téléchargement ici doit suivre la norme du formulaire de téléchargement de fichiers w3c, veuillez vérifier les informations vous-même.

En fait, l'idée est très simple, mais le fonctionnement réel est quand même assez gênant. J'ai aussi rencontré beaucoup d'embûches dans le processus. C'est aussi parce que mon nœud est immature. utilisé pour le transfert!

Passons directement au code : le code est quand même clair :

server.js, permet de démarrer le service et de le faire suivre.

var http = require("http");
var url = require("url");
var fs = require(&#39;fs&#39;);
const querystring = require("querystring");
var path = require(&#39;path&#39;);
var formidable = require(&#39;formidable&#39;),
    os = require(&#39;os&#39;),
    util = require(&#39;util&#39;);

var config = require(&#39;./config&#39;).types; //

var netServerUrlFlag = require(&#39;./config&#39;).netServerUrlFlag;
var netServerhost = require(&#39;./config&#39;).netServerhost;
var netServerport = require(&#39;./config&#39;).netServerport;

var javaServerUrlFlag = require(&#39;./config&#39;).javaServerUrlFlag;
var javaServerhost = require(&#39;./config&#39;).javaServerhost;
var javaServerport = require(&#39;./config&#39;).javaServerport;

var fileServerUrlFlag = require(&#39;./config&#39;).fileServerUrlFlag;

var webapp = require(&#39;./config&#39;).webapp;
var PORT = require(&#39;./config&#39;).webport;
/**
 * 上传文件
 * @param files     经过formidable处理过的文件
 * @param req        httpRequest对象
 * @param postData    额外提交的数据
 */
function uploadFile(files, req, postData) {
    var boundaryKey = Math.random().toString(16);
    var endData = &#39;\r\n----&#39; + boundaryKey + &#39;--&#39;;
    var filesLength = 0, content;

    // 初始数据，把post过来的数据都携带上去
    content = (function (obj) {
        var rslt = [];
        Object.keys(obj).forEach(function (key) {
            arr = [&#39;\r\n----&#39; + boundaryKey + &#39;\r\n&#39;];
            arr.push(&#39;Content-Disposition: form-data; name="&#39; + obj[key][0] + &#39;"\r\n\r\n&#39;);
            arr.push(obj[key][1]);
            rslt.push(arr.join(&#39;&#39;));
        });
        return rslt.join(&#39;&#39;);
    })(postData); 

    // 组装数据
    Object.keys(files).forEach(function (key) {
        if (!files.hasOwnProperty(key)) {
            delete files.key;
            return;
        }
        content += &#39;\r\n----&#39; + boundaryKey + &#39;\r\n&#39; +
            &#39;Content-Type: application/octet-stream\r\n&#39; +
            &#39;Content-Disposition: form-data; name="&#39; + files[key][0] + &#39;"; &#39; +
            &#39;filename="&#39; + files[key][1].name + &#39;"; \r\n&#39; +
            &#39;Content-Transfer-Encoding: binary\r\n\r\n&#39;;
        files[key].contentBinary = new Buffer(content, &#39;utf-8&#39;);;
        filesLength += files[key].contentBinary.length + fs.statSync(files[key][1].path).size;
    });
    req.setHeader(&#39;Content-Type&#39;, &#39;multipart/form-data; boundary=--&#39; + boundaryKey);
    req.setHeader(&#39;Content-Length&#39;, filesLength + Buffer.byteLength(endData));

    // 执行上传
    var allFiles = Object.keys(files);
    var fileNum = allFiles.length;
    var uploadedCount = 0;
    allFiles.forEach(function (key) {
        req.write(files[key].contentBinary);
        console.log("files[key].path:" + files[key][1].path);
        var fileStream = fs.createReadStream(files[key][1].path, { bufferSize: 4 * 1024 });
        fileStream.on(&#39;end&#39;, function () {
            // 上传成功一个文件之后，把临时文件删了
            fs.unlink(files[key][1].path);
            uploadedCount++;
            if (uploadedCount == fileNum) {
                // 如果已经是最后一个文件，那就正常结束
                req.end(endData);
            }
        });
        fileStream.pipe(req, { end: false });
    });
}
var server = http.createServer(function (request, response) {
    var clientUrl = request.url;
    var url_parts = url.parse(clientUrl); //解析路径
    var pathname = url_parts.pathname;

    var sreq = request;
    var sres = response;
    // .net 转发请求
    if (pathname.match(netServerUrlFlag) != null) {
        var clientUrl2 = clientUrl.replace("/" + netServerUrlFlag, &#39;&#39;);
        console.log(".net转发请求......" + clientUrl2);
        var pramsJson = &#39;&#39;;
        sreq.on("data", function (data) {
            pramsJson += data;
        }).on("end", function () {
            var contenttype = request.headers[&#39;content-type&#39;];
            if (contenttype == undefined || contenttype == null || contenttype == &#39;&#39;) {
                var opt = {
                    host: netServerhost, //跨域访问的主机ip
                    port: netServerport,
                    path: clientUrl2,
                    method: request.method,
                    headers: {
                        &#39;Content-Length&#39;: Buffer.byteLength(pramsJson)
                    }
                }
            } else {
                var opt = {
                    host: netServerhost, //跨域访问的主机ip
                    port: netServerport,
                    path: clientUrl2,
                    method: request.method,
                    headers: {
                        &#39;Content-Type&#39;: request.headers[&#39;content-type&#39;],
                        &#39;Content-Length&#39;: Buffer.byteLength(pramsJson)
                    }
                }
            }
            console.log(&#39;method&#39;, opt.method);

            var body = &#39;&#39;;
            var req = http.request(opt, function (res) {
                res.on(&#39;data&#39;, function (data) {
                    body += data;
                }).on(&#39;end&#39;, function () {
                    response.write(body);
                    response.end();
                });
            }).on(&#39;error&#39;, function (e) {
                response.end(&#39;内部错误，请联系管理员！MSG:&#39; + e);
                console.log("error: " + e.message);
            })
            req.write(pramsJson);
            req.end();
        })

    } else
        // java 转发请求
        if (pathname.match(javaServerUrlFlag) != null) {
            response.setHeader("Content-type", "text/plain;charset=UTF-8");

            var clientUrl2 = clientUrl.replace("/" + javaServerUrlFlag, &#39;&#39;);
            console.log(".java转发请求......http://" + javaServerhost + ":" + javaServerport + "" + clientUrl2);
            var prams = &#39;&#39;;
            sreq.on("data", function (data) {
                prams += data;
            }).on("end", function () {
                console.log("client pramsJson>>>>>" + prams);
                const postData = prams;
                console.log("client pramsJson>>>>>" + postData);
                var contenttype = request.headers[&#39;content-type&#39;];
                if (contenttype == undefined || contenttype == null || contenttype == &#39;&#39;) {
                    var opt = {
                        host: javaServerhost, //跨域访问的主机ip
                        port: javaServerport,
                        path: "/hrrp" + clientUrl2,
                        method: request.method,
                        headers: {
                            &#39;Content-Length&#39;: Buffer.byteLength(postData)
                        }
                    }
                } else {
                    var opt = {
                        host: javaServerhost, //跨域访问的主机ip
                        port: javaServerport,
                        path: "/hrrp" + clientUrl2,
                        method: request.method,
                        headers: {
                            &#39;Content-Type&#39;: request.headers[&#39;content-type&#39;],
                            &#39;Content-Length&#39;: Buffer.byteLength(postData)
                        }
                    }
                }
                var body = &#39;&#39;;

                console.log(&#39;method&#39;, opt.method);
                var req = http.request(opt, function (res) {
                    //console.log("response: " + res.statusCode);
                    res.on(&#39;data&#39;, function (data) {
                        body += data;
                    }).on(&#39;end&#39;, function () {
                        response.write(body);
                        response.end();
                        //console.log("end:>>>>>>>" + body);
                    });
                }).on(&#39;error&#39;, function (e) {
                    response.end(&#39;内部错误，请联系管理员！MSG:&#39; + e);
                    console.log("error: " + e.message);
                })

                req.write(postData);
                req.end();


            })
        } else if (pathname.match(fileServerUrlFlag) != null) {
            //文件拦截保存到本地
            var form = new formidable.IncomingForm(),
                files = [],
                fields = [];
            form.uploadDir = os.tmpdir();
            form.on(&#39;field&#39;, function (field, value) {
                console.log(field, value);
                fields.push([field, value]);
            }).on(&#39;file&#39;, function (field, file) {
                console.log(field, file);
                files.push([field, file]);
            }).on(&#39;end&#39;, function () {
                //
                var clientUrl2 = clientUrl.replace("/" + fileServerUrlFlag, &#39;&#39;);
                var opt = {
                    host: netServerhost, //跨域访问的主机ip
                    port: netServerport,
                    path: clientUrl2,
                    method: request.method
                }
                var body = &#39;&#39;;
                var req = http.request(opt, function (res) {
                    res.on(&#39;data&#39;, function (data) {
                        body += data;
                    }).on(&#39;end&#39;, function () {
                        response.write(body);
                        response.end();
                    });
                }).on(&#39;error&#39;, function (e) {
                    response.end(&#39;内部错误，请联系管理员！MSG:&#39; + e);
                    console.log("error: " + e.message);
                })
                //文件上传
                uploadFile(files, req, fields);
            });
            form.parse(sreq);
        }
        else {
            var realPath = path.join(webapp, pathname); //这里设置自己的文件名称;
            var ext = path.extname(realPath);
            ext = ext ? ext.slice(1) : &#39;unknown&#39;;
            fs.exists(realPath, function (exists) {
                //console.log("file is exists："+exists+" file path: " + realPath + "");
                if (!exists) {
                    response.writeHead(404, {
                        &#39;Content-Type&#39;: &#39;text/plain&#39;
                    });

                    response.write("This request URL " + pathname + " was not found on this server.");
                    response.end();
                } else {
                    fs.readFile(realPath, "binary", function (err, file) {
                        if (err) {
                            response.writeHead(500, {
                                &#39;Content-Type&#39;: &#39;text/plain&#39;
                            });
                            //response.end(err);
                            response.end("内部错误，请联系管理员");
                        } else {
                            var contentType = config[ext] || "text/plain";
                            response.writeHead(200, {
                                &#39;Content-Type&#39;: contentType
                            });
                            response.write(file, "binary");
                            response.end();
                        }
                    });
                }
            });

        }
});
server.listen(PORT);
console.log("Server runing at port: " + PORT + ".");

Copier après la connexion

Afficher le code

config.js, pour la configuration.

exports.types = {
  "css": "text/css",
  "gif": "image/gif",
  "html": "text/html",
  "htm": "text/html",
  "ico": "image/x-icon",
  "jpeg": "image/jpeg",
  "jpg": "image/jpeg",
  "js": "text/javascript",
  "json": "application/json",
  "pdf": "application/pdf",
  "png": "image/png",
  "svg": "image/svg+xml",
  "swf": "application/x-shockwave-flash",
  "tiff": "image/tiff",
  "txt": "text/plain",
  "wav": "audio/x-wav",
  "wma": "audio/x-ms-wma",
  "wmv": "video/x-ms-wmv",
  "xml": "text/xml"
};

exports.netServerUrlFlag = "NETSERVER";
exports.netServerhost = "";
exports.netServerport = "";

exports.javaServerUrlFlag = "JAVASERVER";
exports.javaServerhost = ""; //转发的地址
exports.javaServerport = "";//转发的端口

exports.fileServerUrlFlag="FileUpload";
exports.webapp = "public";//项目目录

exports.webport = "82";  //项目启动端口

Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!