Node.js의 TCP/IP 데이터 통신에 대한 자세한 설명-JS 튜토리얼-php.cn

Node.js의 TCP/IP 데이터 통신에 대한 자세한 설명

小云云

풀어 주다： 2018-01-25 11:23:23

원래의

2033명이 탐색했습니다.

이 글은 주로 Node.js 학습을 위한 TCP/IP 데이터 통신에 대한 글(예제 설명)을 제공합니다. 에디터가 꽤 좋다고 생각해서 지금 공유해서 참고용으로 올려보겠습니다. 편집자를 따라 살펴보겠습니다. 모두에게 도움이 되기를 바랍니다.

1. net 모듈을 사용하여 TCP 기반 데이터 통신 구현

TCP 서버와 TCP 클라이언트 간 통신 구현 전용 net 모듈 제공

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 서버가 수신하는 소켓 포트 개체입니다. createServer 메서드는 생성된 TCP 서버를 반환합니다.

클라이언트가 서버와 연결을 설정하면 연결 이벤트가 트리거됩니다. 콜백 함수를 실행하는 방법은 다음과 같습니다

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

로그인 후 복사

나타나는 결과는 다음과 같습니다.

소켓 포트 개체의 예:

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 Create 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服务器被关闭。');
})

로그인 후 복사

in Node.js 다음 방법을 사용하면 클라이언트 또는 서버에 지속적으로 탐지 패킷을 보낼 수 있습니다.

socket.setKeepAlive([enable],[initialDelay])
//enable:true:启用Keep-alive机制，不断向对方发送一个探测包，如果没有回应表示连接关闭
initialDelay：间隔时间（毫秒）

로그인 후 복사