Node acts as a transit server and forwards the interface

Home

Web Front-end

JS Tutorial

Node acts as a transit server and forwards the interface - Shi Haibin

一个新手

Oct 19, 2017 am 09:46 AM

node interface server

Query various information and organize the incomplete interface of a buddy on the Internet. Done, you can use the forwarding service!

Since the project is separating the front-end and back-end, involving cross-domain and protocol issues, I was temporarily overwhelmed and chose to use nodejs for transit. I think many people should use it. But there is no problem in forwarding ordinary forms. When uploading and forwarding attachments, all kinds of pain have been solved!

1. The project is quite special. It has two platforms in the background, one is java and the other is donet, which is quite useless. I will not explain the specific reasons.

2. When doing node forwarding, there is no file forwarding operation at the beginning, so it is very simple. The user can intercept whatever is passed in and forward it, and everything is fine!

3. File forwarding is very troublesome. My idea is to save files uploaded by users to the node server. Use formidable .

Install via npm:

npm install formidable@latest

Copy after login

Use it to transfer files and save them to a temporary directory to get file information.

Reorganize through the file package. to upload. Note that the upload here must follow the w3c file upload form standard, please check the information yourself.

In fact, the idea is very simple, but the actual operation is still quite troublesome. I also encountered a lot of pitfalls in the process. It is because my node is immature. After all, it is only used for transfer!

Let’s go directly to the code: it’s still clear when you look at the code:

server.js, used to start the service and forward it.

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 + ".");

Copy after login

View Code

config.js, for 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";  //项目启动端口

Copy after login

The above is the detailed content of Node acts as a transit server and forwards the interface - Shi Haibin. For more information, please follow other related articles on the PHP Chinese website!

Statement of this Website

The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

Hot AI Tools

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress images for free

Clothoff.io

AI clothes remover

AI Hentai Generator

Generate AI Hentai for free.

Hot Article

R.E.P.O. Energy Crystals Explained and What They Do (Yellow Crystal)

4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

R.E.P.O. Best Graphic Settings

4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

Assassin's Creed Shadows: Seashell Riddle Solution

2 weeks ago By DDD

R.E.P.O. How to Fix Audio if You Can't Hear Anyone

4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

R.E.P.O. Chat Commands and How to Use Them

4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

Hot Tools

Notepad++7.3.1

Easy-to-use and free code editor

SublimeText3 Chinese version

Chinese version, very easy to use

Zend Studio 13.0.1

Powerful PHP integrated development environment

Dreamweaver CS6

Visual web development tools

SublimeText3 Mac version

God-level code editing software (SublimeText3)

Hot Topics

Where is the login entrance for gmail email?

7523

CakePHP Tutorial

1378

What is the format of the account name of steam

win11 activation key permanent

nyt connections hints and answers

Related knowledge

How to configure Dnsmasq as a DHCP relay server Mar 21, 2024 am 08:50 AM

The role of a DHCP relay is to forward received DHCP packets to another DHCP server on the network, even if the two servers are on different subnets. By using a DHCP relay, you can deploy a centralized DHCP server in the network center and use it to dynamically assign IP addresses to all network subnets/VLANs. Dnsmasq is a commonly used DNS and DHCP protocol server that can be configured as a DHCP relay server to help manage dynamic host configurations in the network. In this article, we will show you how to configure dnsmasq as a DHCP relay server. Content Topics: Network Topology Configuring Static IP Addresses on a DHCP Relay D on a Centralized DHCP Server

Best Practice Guide for Building IP Proxy Servers with PHP Mar 11, 2024 am 08:36 AM

In network data transmission, IP proxy servers play an important role, helping users hide their real IP addresses, protect privacy, and improve access speeds. In this article, we will introduce the best practice guide on how to build an IP proxy server with PHP and provide specific code examples. What is an IP proxy server? An IP proxy server is an intermediate server located between the user and the target server. It acts as a transfer station between the user and the target server, forwarding the user's requests and responses. By using an IP proxy server

What are the internal interfaces of a computer motherboard? Recommended introduction to the internal interfaces of a computer motherboard Mar 12, 2024 pm 04:34 PM

When we assemble the computer, although the installation process is simple, we often encounter problems in the wiring. Often, users mistakenly plug the power supply line of the CPU radiator into the SYS_FAN. Although the fan can rotate, it may not work when the computer is turned on. There will be an F1 error "CPUFanError", which also causes the CPU cooler to be unable to adjust the speed intelligently. Let's share the common knowledge about the CPU_FAN, SYS_FAN, CHA_FAN, and CPU_OPT interfaces on the computer motherboard. Popular science on the CPU_FAN, SYS_FAN, CHA_FAN, and CPU_OPT interfaces on the computer motherboard 1. CPU_FANCPU_FAN is a dedicated interface for the CPU radiator and works at 12V

Common programming paradigms and design patterns in Go language Mar 04, 2024 pm 06:06 PM

As a modern and efficient programming language, Go language has rich programming paradigms and design patterns that can help developers write high-quality, maintainable code. This article will introduce common programming paradigms and design patterns in the Go language and provide specific code examples. 1. Object-oriented programming In the Go language, you can use structures and methods to implement object-oriented programming. By defining a structure and binding methods to the structure, the object-oriented features of data encapsulation and behavior binding can be achieved. packagemaini

What should I do if I can't enter the game when the epic server is offline? Solution to why Epic cannot enter the game offline Mar 13, 2024 pm 04:40 PM

What should I do if I can’t enter the game when the epic server is offline? This problem must have been encountered by many friends. When this prompt appears, the genuine game cannot be started. This problem is usually caused by interference from the network and security software. So how should it be solved? The editor of this issue will explain I would like to share the solution with you, I hope today’s software tutorial can help you solve the problem. What to do if the epic server cannot enter the game when it is offline: 1. It may be interfered by security software. Close the game platform and security software and then restart. 2. The second is that the network fluctuates too much. Try restarting the router to see if it works. If the conditions are OK, you can try to use the 5g mobile network to operate. 3. Then there may be more

Pi Node Teaching: What is a Pi Node? How to install and set up Pi Node? Mar 05, 2025 pm 05:57 PM

Detailed explanation and installation guide for PiNetwork nodes This article will introduce the PiNetwork ecosystem in detail - Pi nodes, a key role in the PiNetwork ecosystem, and provide complete steps for installation and configuration. After the launch of the PiNetwork blockchain test network, Pi nodes have become an important part of many pioneers actively participating in the testing, preparing for the upcoming main network release. If you don’t know PiNetwork yet, please refer to what is Picoin? What is the price for listing? Pi usage, mining and security analysis. What is PiNetwork? The PiNetwork project started in 2019 and owns its exclusive cryptocurrency Pi Coin. The project aims to create a one that everyone can participate

How to install PHP FFmpeg extension on server? Mar 28, 2024 pm 02:39 PM

How to install PHPFFmpeg extension on server? Installing the PHPFFmpeg extension on the server can help us process audio and video files in PHP projects and implement functions such as encoding, decoding, editing, and processing of audio and video files. This article will introduce how to install the PHPFFmpeg extension on the server, as well as specific code examples. First, we need to ensure that PHP and FFmpeg are installed on the server. If FFmpeg is not installed, you can follow the steps below to install FFmpe

Introduction to PHP interfaces and how to define them Mar 23, 2024 am 09:00 AM

Introduction to PHP interface and how it is defined. PHP is an open source scripting language widely used in Web development. It is flexible, simple, and powerful. In PHP, an interface is a tool that defines common methods between multiple classes, achieving polymorphism and making code more flexible and reusable. This article will introduce the concept of PHP interfaces and how to define them, and provide specific code examples to demonstrate their usage. 1. PHP interface concept Interface plays an important role in object-oriented programming, defining the class application

See all articles