本文主要为大家带来一篇node.js学习之tcp/ip数据通讯(实例讲解)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧，希望能帮助到大家。
1.使用net模块实现基于tcp的数据通讯
提供了一个net模块，专用于实现tcp服务器与tcp客户端之间的通信
1.1创建tcp服务器
在node.js利用net模块创建tcp服务器
var server = net.createserver([options],[connectionlistener])
//options：false当tcp服务器接收到客户端发送的一个fin包时将会回发一个fin包
true当tcp服务器接收到客户端发送的一个fin包时将不会回发fin包，这使得tcp服务器可以继续向客户端发送数据，但不会继续接收客户端发送的数据。来发者必须调用end方法来关闭socket连接。默认为false
connectionlistener：指定当客户端与服务器端简历连接时所要调用的回调函数
function(socket){
//回调函数代码
}
参数值为tcp服务器监听的socket端口对象createserver方法返回被创建的tcp服务器
当客户端与服务器建立连接时，触发connection事件，可以利用下面方式执行回调函数
server.on('connection',function(socket){
//回调函数代码
})
在创建tcp服务器后，使用listen方法通知服务器开始监听客户端连接
server.listen(port,[host],[backlog],[callback])
//port指定需要监听的端口号，
host：指定需要监听的ip地址或主机名，如果省略，服务器将监听来自于任何ipv4地址的客户端连接
backlog：指定位于等待队列中的客户端连接的最大数量
callback：无参回调函数
server.listen(path,[callback])
//server:代表一个使用unix端口的服务器
path：指定需要监听的路径，会触发listening事件，然后执行回调函数callback
server.listenting（handle，[callback]）
//server 代表一个tcp服务器
handle：指定需要监听的socket句柄（该句柄可以为一个tcp服务器对象，socket端口对象，文件描述符）
现举例创建一个tcp服务器：
var net = require('net')
var server = net.createserver(function(socket){
console.log('客户端与服务器连接已建立')
})
server.listen(8431,'localhost',function(){
console.log('服务器端开始监听')
})
运行后可得如下结果：
利用telnet访问对应的服务器：
telnet localhost 8431
会出现的结果如下：
socket端口对象举例：
var net = require('net')
var file = require('fs').createwritestream('./message.txt');
var server = net.createserver(function(socket){
console.log('客户端与服务器连接已建立')
server.getconnections(function(err,count){
console.log('当前存在%d个客户端连接。',count);
server.maxconnections = 4;
console.log('tcp服务器的最大连接数为%d',server.maxconnections);
})
// server.close(function(){
// console.log('tcp服务器被关闭。');
// })
})
server.listen(8431,'localhost',function(){
console.log('服务器端开始监听')
})
server.on('connection',function(socket){
address = socket.address();
console.log('被监视的地址信息为%j',address);
socket.pipe(file);
socket.setencoding('utf8');
socket.on('data',function(data){
console.log(data.tostring());
console.log('已接受到%d字节数据。',socket.bytesread);
});
socket.on('end',function(){
file.end('再见')
console.log('客户端连接被关闭。')
})
socket.pause();
settimeout(function(){
console.log('*************')
socket.resume();
socket.pipe(file,{end:false});
},30*1000);
// socket.pipe(file,{end:false});
// settimeout(function(){
// file.end('再见。');
// socket.unpipe(file);
// },5000);
socket.settimeout(10*1000);
socket.on('timeout',function(){
console.log('客户端连接超时');
socket.settimeout(0);
})
})
1.2 创建tcp客户端
建立tcp客户端举例：
var net = require(net);
var client = new net.socket();
client.setencoding('utf8');
client.connect(8431,'localhost',function(){
console.log('已连接到服务器');
client.write('你好');
console.log('当前已发送%d字节',client.byteswritten);
client.end('再见')
console.log('当前已发送%d字节',client.byteswritten);
// settimeout(function(){
// client.end('再见');
// },10*1000)
});
client.on('data',function(data){
//console.log('已接收服务器端发送的数据： '+data);
console.log('已接收服务器端发送的数据');
})
client.on('error',function(err){
console.log('与服务器连接或通信的过程中发生了一个错误，错误编码为%s',err.code);
client.destroy();
})
同时需要建立对应的服务器：
var net = require('net');
var fs = require('fs');
var server = net.createserver();
server.on('connection',function(socket){
console.log('客户端与服务器端连接已建立');
socket.setencoding('utf8');
var readstream = fs.createreadstream('./server.js');
readstream.on('data',function(data){
var flag = socket.write(data);
console.log('write方法的返回值为：'+flag);
console.log('缓存队列中当前缓存了%d字符。',socket.buffersize);
})
socket.on('data',function(data){
console.log('已连接客户端发送的数据:'+data);
socket.write('确认数据：'+data);
})
socket.on('error',function(err){
console.log('客户端通信的过程中发生了一个错误，错误编码为%s',err.code);
socket.destroy();
})
socket.on('end',function(){
console.log('客户端连接被关闭。');
server.unref();
})
socket.on('close',function(had_error){
if(had_error){
console.log('由于一个错误导致socket端口被关闭。');
server.unref();
}else{
console.log('socket端口被正常关闭。');
}
})
server.getconnections(function(err,count){
if(count==2)
server.close();
});
});
server.listen(8431,'localhost');
server.on('close',function(){
console.log('tcp服务器被关闭。');
})
在node.js中利用下面方法可以向客户端或服务器不断发送探测包，以确定连接状态；
socket.setkeepalive([enable],[initialdelay])
//enable:true:启用keep-alive机制，不断向对方发送一个探测包，如果没有回应表示连接关闭
initialdelay：间隔时间（毫秒）
相关推荐：
node.js创建web、tcp服务器
浅析tcp传输的三次握手四次挥手策略
tcp/ip与udp究竟有什么区别
以上就是node.js之tcp/ip数据通讯详解的详细内容。