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连接。默认为falseconnectionListener：指定当客户端与服务器端简历连接时所要调用的回调函数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事件，然后执行回调函数callbackserver.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学习之TCP/IP数据通讯(实例讲解)就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。
