nodejs的TCP相关的一些笔记

 1 const net = require('net'); 2//创建服务实例 3 const server = net.createServer(); 4 const PORT = 12306; 5 const HOST = 'localhost'; 6//服务启动对网络资源的监听 7server.listen(PORT, HOST); 8//当服务启动时触发的事件 9 server.on('listening', ()=>{10    console.log(`服务已开启在 ${HOST}: ${PORT}`);11});12//接收消息，响应消息13 server.on('connection', (socker) => {14//通过Socket上的data事件接收消息15     socker.on('data', (chunk) => {//通过Socket上的writer方法回写响应数据16         const msg = chunk.toString();17        console.log(msg);18//通过Socket上的writer方法回写响应数据19         socker.write('您好' + msg);20    });21});22 server.on('close', ()=>{23     console.log('服务端关闭了');24});25 server.on('error', (err) =>{26if(err.code === 'EADDRINUSE'){27         console.log('地址正在被使用');28     }else{29        console.log(err);30    }31 });

 1 const net = require('net'); 2//创建客户实例,并与服务端建立连接 3 const client = net.createConnection({ 4     port:12306, 5     host:'127.0.0.1' 6}); 7//当套字节与服务端连接成功时触发connect事件 8 client.on('connect', () =>{ 9     client.write('他乡踏雪');//向服务端发送数据10});11//使用data事件监听服务端响应过来的数据12 client.on('data', (chunk) => {13    console.log(chunk.toString());14});15 client.on('error', (err)=>{16    console.log(err);17});18 client.on('close', ()=>{19     console.log('客户端断开连接');20 });

listening:调用server.listen()绑定端口或者Domain Socket后触发。
connection:每个客户端套字节连接到服务器时触发，其回调函数会接收到一个Socket实例作为参数。
close:当服务器关闭时触发，在调用server.close()后，服务器将停止接收新的套字节连接，但保持当前存在的连接，等待所有连接断开后，会触发该事件。
error:当服务器发生异常时，将会触发该事件。

data:当一端调用write()方法发送数据时，另一端会触发data事件，事件传递的数据即是write()发送的数据。
end:当连接中的任意一段发送了FIN数据时，将会触发该事件。
connect:该事件用于客户端，当套字节与服务器连接成功后会触发。
drain:当任意一端调用write()发送数据时，当前端会触发该事件。
error:当异常发生时，触发该事件。
close:当套字节完全关闭时，触发该事件。
timeout:当一定事件后连接不在活跃时，该事件将会触发，通知用户当前连接已经被闲置。

//在客户端的connect事件回调中通过多个write()发送数据，它可能会将多次write()写入的数据一次发出
client.on('connect', () =>{
    client.write('他乡踏雪');//向服务端发送数据
    client.write('他乡踏雪1');
    client.write('他乡踏雪2');
    client.write('他乡踏雪3');
});

 1 let dataArr = ["他乡踏雪","他乡踏雪","他乡踏雪"]; 2//当套字节与服务端连接成功时触发connect事件 3 client.on('connect', () =>{ 4     client.write('他乡踏雪');//向服务端发送数据 5for(let i = 0; i< dataArr.length; i++){ 6         (function(data, index){ 7             setTimeout(()=>{ 8                client.write(data); 9             },1000 * i);10        })(dataArr[i], i);11    }12 });

发送端多次write()的数据可能被打包成一个数据包发送到接收端。
发送端通过write()一次写入的数据可能因为Nagle算法的优化被截断到两个数据包中。

消息头：也就是间隔数据的标识，采用定长的方式就可以实现有规律的获取这些数据标识。消息头中包括消息系列号、消息长度。
消息体：要传输的数据本身。

 1class MyTransformCode{ 2    constructor(){ 3this.packageHeaderLen = 4;//设置定长的消息头字节长度 4this.serialNum = 0;//消息序列号 5this.serialLen = 2;//消息头中每个数据占用的字节长度（序列号、消息长度值） 6    } 7//编码 8     encode(data, serialNum){//data:当前write()实际要传输的数据； serialNum:当前消息的编号 9         const body = Buffer.from(data);//将要传输的数据转换成二进制10//01 先按照指定的长度来申请一片内存空间作为消息头header来使用11         const headerBuf = Buffer.alloc(this.packageHeaderLen);12//02写入包的头部数据13         headerBuf.writeInt16BE(serialNum ||this.serialNum);//将当前消息编号以16进制写入14         headerBuf.writeInt16BE(body.length,this.serialLen);//将当前write()写入的数据的二进制长度作为消息的长度写入15if(serialNum === undefined){16this.serialNum ++;//如果没有传入指定的序列号，表示在最佳写入，消息序列号+117        }18return Buffer.concat([headerBuf, body]);//将消息头和消息体合并成一个Buffer返回，交给TCP发送端19    }20//解码21    decode(buffer){22         const headerBuf = buffer.slice(0,this.packageHeaderLen);//获取消息头的二进制数据23         const bodyBuf = buffer.slice(this.packageHeaderLen);//获取消息体的二进制数据24return {25            serialNum:headerBuf.readInt16BE(),26             bodyLength:headerBuf.readInt16BE(this.serialLen),27            body:bodyBuf.toString()28        };29    }30//获取数据包长度的方法31    getPackageLen(buffer){32if(buffer.length <this.packageHeaderLen){33return 0;//当数据长度小于数据包头部的长度时，说明它的数据是不完整的，返回0表示数据还没有完全传输到接收端34         }else{35returnthis.packageHeaderLen + buffer.readInt16BE(this.serialLen);//数据包头部长度+加上数据包消息体的长度(从数据包的头部数据中获取)，就是数据包的实际长度36        }37    }38}39 module.exports = MyTransformCode;

let tf =new MyTransformCode();
let str= "他乡踏雪";
let buf= tf.encode(str);//编码
console.log(tf.decode(buf));//解码
console.log(tf.getPackageLen(buf));//获取数据包字节长度
//测试结果
{ serialNum: 0, bodyLength: 12, body: '他乡踏雪' }16

 1//应用封包解决TCP粘包问题服务端 2 const net = require('net'); 3 const MyTransform = require('./myTransform.js'); 4 const server = net.createServer();//创建服务实例 5 let overageBuffer =null;//缓存每一次data传输过来不完整的数据包，等待一下次data事件触发时与chunk合并处理 6 let tsf =new MyTransform(); 7 server.listen('12306', 'localhost'); 8 server.on('listening',()=>{ 9     console.log('服务端运行在 localhost:12306');10});11 server.on('connection', (socket)=>{12     socket.on('data', (chunk)=>{13if(overageBuffer && overageBuffer.length > 0){14             chunk = Buffer.concat([overageBuffer, chunk]);//如果上一次data有未不完成的数据包的数据片段，合并到这次chunk前面一起处理15        }16while(tsf.getPackageLen(chunk) && tsf.getPackageLen(chunk) <= chunk.length){//如果接收到的数据中第一个数据包是完整的，进入循环体对数据进行拆包处理17             let packageLen = tsf.getPackageLen(chunk);//用于缓存接收到的数据中第一个包的字节长度18             const packageCon = chunk.slice(0, packageLen);//截取接收到的数据的第一个数据包的数据19             chunk = chunk.slice(packageLen);//截取除第一个数据包剩余的数据，用于下一轮循环或下一次data事件处理20             const ret = tsf.decode(packageCon);//解码当前数据中第一个数据包21            console.log(ret);22             socket.write(tsf.encode(ret.body, ret.serialNum));//讲解码的数据报再次封包发送回客户端23        };24         overageBuffer = chunk;//缓存不完整的数据包，等待下一次data事件接收到数据后一起处理25    });26 });

 1//应用封包解决TCP粘包问题客户端 2 const net = require('net'); 3 const MyTransform = require('./myTransform.js'); 4 let overageBuffer =null; 5 let tsf =new MyTransform(); 6 const client = net.createConnection({ 7     host:'localhost', 8     port:12306 9});10 client.write(tsf.encode("他乡踏雪1"));11 client.write(tsf.encode("他乡踏雪2"));12 client.write(tsf.encode("他乡踏雪3"));13 client.write(tsf.encode("他乡踏雪4"));14 client.on('data', (chunk)=>{15if(overageBuffer && overageBuffer.length > 0){16         chunk = Buffer.concat([overageBuffer, chunk]);////如果上一次data有未不完成的数据包的数据片段，合并到这次chunk前面一起处理17    }18while(tsf.getPackageLen(chunk) && tsf.getPackageLen(chunk) <= chunk.length){//如果接收到的数据中第一个数据包是完整的，进入循环体对数据进行拆包处理19         let packageLen = tsf.getPackageLen(chunk);//用于缓存接收到的数据中第一个包的字节长度20         const packageCon = chunk.slice(0, packageLen);//截取接收到的数据的第一个数据包的数据21         chunk = chunk.slice(packageLen);//截取除第一个数据包剩余的数据，用于下一轮循环或下一次data事件处理22         const ret = tsf.decode(packageCon);//解码当前数据中第一个数据包23        console.log(ret);24    };25     overageBuffer = chunk;//缓存不完整的数据包，等待下一次data事件接收到数据后一起处理26 });