AJax技术

Node.js学习之TCP/IP数据通讯(实例讲解)

字号+ 作者:H5之家 来源:H5之家 2017-11-06 10:06 我要评论( )

下面小编就为大家带来一篇Node.js学习之TCP/IP数据通讯(实例讲解)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧

时间:2017-10-12来源: 作者:源码库 文章热度: ℃

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学习之TCP/IP数据通讯(实例讲解)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持ASPKU源码库。


注:相关教程知识阅读请移步到频道。

 

1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

相关文章
  • XMLHttpRequest中的url有什么用?

    XMLHttpRequest中的url有什么用?

    2017-02-17 17:00

网友点评