前言
想必我们在用Node.js用的最多的应该是创建http服务，所以对于每个Web开发工程师而言，Node.js的网络相关模块学习是必不可少。
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进行桥接相互通信。
Net模块
Net模块提供了一些用于底层的网络通信接口，包括创建服务器以及客户端，其中HTTP模块也是基于Net模型的上层封装，在Net模块里面主要提供net.Server以及net.Socket
创建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这个构造体主要有提供一些什么方法、监听事件的使用。
相关事件
allowHalfOpen == false)socket会自我销毁(如果写入待处理队列里面还没正式响应回包)，但是我们可以设置allowHalfOpen参数为true，这样可以继续往该socket里面写数据，但是我们需要自己去调用 end 方法去消耗这个socket，不然可能会造成句柄泄漏。相关方法
相关属性
undefined。回包异常处理
服务器从客户端接受到需要处理的数据后进入处理环节，再业务逻辑处理完成之前如果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;
});
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持亿速云。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
