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

前端之家收集整理的这篇文章主要介绍了Node.js学习之TCP/IP数据通讯(实例讲解)前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

1.使用net模块实现基于TCP的数据通讯

提供了一个net模块,专用于实现TCP服务器与TCP客户端之间的通信

1.1创建TCP服务器

在Node.js利用net模块创建TCP服务器

调用end方法关闭socket连接。默认为false connectionListener:指定当客户端与服务器端简历连接时所要调用的回调函数 function(socket){ //回调函数代码 }

参数值为TCP服务器监听的socket端口对象createServer方法返回被创建的TCP服务器

当客户端与服务器建立连接时,触发connection事件,可以利用下面方式执行回调函数

函数代码 })

在创建TCP服务器后,使用listen方法通知服务器开始监听客户端连接

数量 callback:无参回调函数

server.listen(path,[callback])
//server:代表一个使用unix端口的服务器
path:指定需要监听的路径,会触发listening事件,然后执行回调函数callback

server.listenting(handle,[callback])
//server 代表一个TCP服务器
handle:指定需要监听的socket句柄(该句柄可以为一个TCP服务器对象,socket端口对象,文件描述符)

现举例创建一个TCP服务器:

运行后可得如下结果:

利用telnet访问对应的服务器:

会出现的结果如下:

socket端口对象举例:

})

// server.close(function(){
// console.log('TCP服务器被关闭。');
// })
})
server.listen(8431,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});
},301000);
// 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客户端举例:

});
client.on('data',function(data){
//console.log('已接收服务器端发送的数据: '+data);
console.log('已接收服务器端发送的数据');
})
client.on('error',function(err){
console.log('与服务器连接或通信的过程中发生了一个错误错误编码为%s',err.code);
client.destroy();
})

同时需要建立对应的服务器:

方法的返回值为:'+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中利用下面方法可以向客户端或服务器不断发送探测包,以确定连接状态;

关闭 initialDelay:间隔时间(毫秒)

以上这篇Node.js学习之TCP/IP数据通讯(实例讲解)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持编程之家。

猜你在找的Node.js相关文章