Node.js之網絡通信模塊淺析

時間 2019-12-06

原文原文鏈接

前言

想必咱們在用Node.js用的最多的應該是建立http服務，因此對於每一個Web開發工程師而言，Node.js的網絡相關模塊學習是必不可少。javascript

Node.js的網絡模塊架構

在Node.js的模塊裏面，與網絡相關的模塊有Net、DNS、HTTP、TLS/SSL、HTTPS、UDP/Datagram，除此以外，還有v8底層相關的網絡模塊有tcp_wrap.cc、udp_wrap.cc、pipe_wrap.cc、stream_wrap.cc等等，在Javascript層以及C++層之間經過process.binding進行橋接相互通訊。java

Net模塊

Net模塊提供了一些用於底層的網絡通訊接口，包括建立服務器以及客戶端，其中HTTP模塊也是基於Net模型的上層封裝，在Net模塊裏面主要提供net.Server以及net.Socketnode

建立TCP服務端

建立一個TCP服務器，能夠經過使用構造函數new net.Server或者使用工廠方法net.createServer，這兩個方法都會返回一個net.Server類，可接收兩個可選參數。算法

var net = require('net');

var server = net.createServer(function(socket){

    socket
        .on('data',function(data){
            console.log('socket data',data.toString());
            socket.write( data.toString() );
        })
        .on('end',function(){
            console.log('socket end')
        })
        .on('error',function(error){
            console.log('socket error',error);
        });
});

server.listen(56200,function(){
    console.log('server run at ',server.address());
});

server.on('error',function(err){
    throw err;
});
// 執行後：server run at { address: '::', family: 'IPv6', port: 56200 }

在listen監聽的時候沒有指定端口的話會自動隨意監聽一個端口，建立完成一個TCP服務器後，使用tenlent 0.0.0.0 56200，連接後可與服務器進行數據通訊。經過createServer實例化一個服務後，服務會去監聽客戶端請求，與客戶端創建了連接以後會在回調裏面拋出建鏈的net.Socket對象。緩存

建立TCP客戶端

建立一個TCP客戶端連接可使用構造函數new net.Socket或者其工廠方法net.createConnection,建立成功後都會返回一個net.Socket實例。安全

var net = require('net');

var client = net.createConnection({port:56200,host:'localhost'});

client.on('connect',function(){
    console.log('client connect');
});

client.on('data',function(data){
    console.log('client data',toString());
});

client.on('error',function(error){
    throw error;
});

client.on('close',function(){
    console.log('client close');
});

Socket

socket是啥這裏就不作詳細的闡述了，下面主要了解下net.Socket這個構造體主要有提供一些什麼方法、監聽事件的使用。服務器

回包異常處理

服務器從客戶端接受到須要處理的數據後進入處理環節，再業務邏輯處理完成以前若是socket之外斷開的話，待服務器再給客戶端回報的時候會直接響應error事件並報錯Error : This socket has benn ended by the other part，因此在回報以前服務端須要先判斷該socket是否被銷燬，若是沒有被銷燬則回包，若是已經斷開則銷燬：

var net = require('net');
var biz = require('./biz');
var server = net.createServer(function(socket){

    socket
        .on('data',function(data){
            biz.do(data)
                .then(function(){
                    if( !socket.destroyed ) {
                        socket.write( data.toString() );
                    } else {
                        // do some report
                        socket.destry();
                    }
                })
                .catch(function(){
                    !socket.destroyed && socket.end('server handler error');
                });
            
        })
        .on('end',function(){
            console.log('socket end')
        })
        .on('error',function(error){
            console.log('socket error',error);
        });
});

server.listen(56200,function(){
    console.log('server run at ',server.address());
});

server.on('error',function(err){
    throw err;
});

限制客戶端數據大小

對請求大小限制是服務安全裏面比不可少的一個環節，服務端不能無限大小的去接受客戶端發送過來的全部數據，而限制大小就是第一道門檻。

var net = require('net');
var MAX_REQUEST_BYTES = 2 * 1024 * 1024;  // 2M
var server = net.createServer(function(socket){

    socket
        .on('data',function(data){
           
            if(data.bytesRead > MAX_REQUEST_BYTES) {
                socket.pause();
                socket.end('data is too big, forbidden');
                // do some report
            }
        })
        .on('end',function(){
            console.log('socket end')
        })
        .on('error',function(error){
            console.log('socket error',error);
        });
});

server.listen(56200,function(){
    console.log('server run at ',server.address());
});

server.on('error',function(err){
    throw err;
});