TCP 서비스는 네트워크 애플리케이션에서 매우 일반적입니다. 현재 대부분의 애플리케이션은 TCP를 기반으로 구축됩니다. net 모듈은 서버와 클라이언트를 생성하는 방법이 포함된 TCP 네트워크 프로그래밍을 위한 비동기 네트워크 래퍼를 제공합니다. 이 기사에서는 nodeJS의 net 모듈을 자세히 소개합니다.
관련 권장사항: "nodejs tutorial"
【net.isIP(input)】
입력이 IP 주소인지 테스트하세요. 문자열이 유효하지 않으면 0을 반환합니다. IPV4인 경우 4, IPV6인 경우 6을 반환
var net = require('net');
console.log(net.isIP('1.1.1.1'));//4
console.log(net.isIP('1.1'));//0
console.log(net.isIP('AD80::ABAA:0000:00C2:0002'));//6【net.isIPv4(input)】
입력 주소가 IPV4인 경우 true를 반환하고, IPV4인 경우 false를 반환
var net = require('net');
console.log(net.isIPv4('1.1.1.1'));//true
console.log(net.isIPv4('1.1'));//false【net.isIPv6(input)】
입력한 주소가 IPV6이면 true, 그렇지 않으면 false를 반환
var net = require('net');
console.log(net.isIPv6('1.1.1.1'));//true
console.log(net.isIPv6('AD80::ABAA:0000:00C2:0002'));//true【net.createServer([options][,connectionListener])】
다음 매개변수로 TCP 서버를 생성합니다
options allowHalfOpen: false(默认)，如果为true，当另一端socket发送FIN包时socket不会自动发送FIN包。socket变为不可读但可写(半关闭) pauseOnConnect: false(默认)，如果为true，当连接到来的时候相关联的socket将会暂停。它允许在初始进程不读取数据情况下，让连接在进程间传递。调用resume()从暂停的socket里读取数据 connectionListener 自动给 'connection' 事件创建监听器
var server = net.createServer(function() {
});【server.listen(port[, 호스트][, backlog][, callback])]
지정된 포트 및 호스트로부터의 연결 수락을 시작합니다. 호스트가 생략되면 서버는 모든 IPv4 주소(INADDR_ANY)로부터의 직접 연결을 허용합니다. 포트가 0이면 임의의 포트가 할당됩니다. 백로그는 연결 대기 대기열의 최대 길이입니다. 실제 길이는 Linux의 tcp_max_syn_backlog 및 somaxconn과 같이 sysctl을 통해 운영 체제에 의해 설정됩니다. 이 매개변수의 기본값은 511
서버 바인딩 시 'listening' 이벤트가 발생합니다. 마지막 매개변수 콜백은 'listening' 이벤트의 리스너로 사용됩니다.
일부 사용자는 요청한 포트에서 다른 서버가 이미 실행 중임을 나타내는 EADDRINUSE 오류가 발생합니다. 이 상황을 처리하는 방법은 잠시 기다렸다가 다시 시도하는 것입니다
server.listen(6000);
【server.close([콜백])】
서버는 새로운 연결 수신을 중단하고 기존 연결을 유지합니다. 모든 연결이 완료되면 서버가 닫히고 'close' 이벤트가 트리거됩니다. 콜백 함수를 전달하여 'close' 이벤트를 수신할 수 있습니다. 존재하는 경우 오류(있는 경우)를 유일한 매개변수로 사용하여 콜백 함수가 호출됩니다.
[server.address()]
운영 체제는 바인딩된 주소, 프로토콜 제품군 이름 및 서버 포트를 반환합니다. 시스템에 의해 바인딩된 포트를 찾을 때 매우 유용합니다
[참고] 'listening' 이벤트가 트리거되기 전에 server.address()를 호출하지 마세요
server.listen(function() {
//{ address: '::', family: 'IPv6', port: 53806 }
console.log(server.address());
});【server.maxConnections】
이 옵션을 설정한 후, 서버 연결 개수가 개수를 초과하면 새 연결을 거부합니다
소켓이 child_process.fork() 메서드를 사용하여 하위 프로세스로 전송되면 이 옵션은 권장되지 않습니다
【server.getConnections(callback)】
비동기적으로 서버 수량의 현재 활성 연결을 얻습니다. 소켓이 하위 프로세스로 전송될 때만 유효합니다.
콜백 함수에는 2개의 매개변수 err과 count가 있습니다
server.getConnections(function(err,count){
console.log(count);//0
})【이벤트 청취】
서버가 바인딩을 위해 server.listen을 호출할 때 트리거됩니다.
【 이벤트 연결】
{Socket object} 连接对象새로운 연결이 생성되면 시작됩니다. 소켓은 net.Socket
의 인스턴스입니다.Socket
【이벤트 종료】
서버가 닫힐 때 발생합니다
[참고] 연결이 있는 경우 모든 연결이 닫힐 때까지 이 이벤트는 발생하지 않습니다
[이벤트 error】
에러 발생 시 Trigger
【net.connect(options[,connectionListener])】
【net.createConnection(options[,connectionListener])】
connect()의 별칭 createConnection() 메소드
Method는 지정된 주소와 포트에 연결된 새로운 'net.Socket'을 반환합니다. 소켓이 설정되면 'connect' 이벤트가 트리거됩니다. 'net.Socket'과 같은 방식입니다
TCP 소켓의 경우 매개변수 옵션은 다음과 같습니다
port: 客户端连接到 Port 的端口（必须） host: 客户端要连接到得主机。默认 'localhost' localAddress: 网络连接绑定的本地接口 localPort: 网络连接绑定的本地端口 family : IP 栈版本。默认 4
로컬 도메인 소켓의 경우 매개변수 옵션은 다음과 같습니다
path: 客户端连接到得路径(必须)
var client = net.connect({port: 5000}, function() {});【new net.Socket ([옵션])】
새 소켓 개체 생성
옵션 개체의 기본값은 다음과 같습니다.
{ fd: null
allowHalfOpen: false,
readable: false,
writable: false
}fd 매개변수를 사용하면 기존 파일 설명자를 지정할 수 있습니다. 이 소켓에서 읽기 또는 쓰기를 허용하려면 읽기 및/또는 쓰기 가능을 true로 설정합니다(매개변수 fd가 유효한 경우에만)
【socket.connect(port[, 호스트][, connectListener])】
【socket.connect. (path[, connectListener])】
수신 소켓을 사용하여 연결을 엽니다. 포트와 호스트가 지정되면 TCP 소켓이 소켓을 엽니다. 호스트 매개변수를 생략하면 기본값은 localhost입니다. path를 지정하면 지정된 경로의 유닉스 소켓으로 소켓이 열립니다
connectListener 매개변수가 'connect' 이벤트에 리스너로 추가됩니다
【socket.write(data[, 인코딩][, callback) ])】
소켓으로 데이터를 보냅니다. 두 번째 매개변수는 문자열의 인코딩을 지정하며, 기본값은 UTF8 인코딩입니다
如果所有数据成功刷新到内核缓冲区，返回true。如果数据全部或部分在用户内存里，返回false。当缓冲区为空的时候会触发'drain'
当数据最终被完整写入的的时候，可选的callback参数会被执行，但不一定会马上执行
【socket.end([data][, encoding])】
半关闭socket。例如，它发送一个FIN包。可能服务器仍在发送数据。
如果参数data不为空，等同于调用socket.write(data,encoding)后再调用socket.end()
【socket.destroy()】
确保没有 I/O 活动在这个套接字上。只有在错误发生情况下才需要
【socket.pause()】
暂停读取数据。就是说，不会再触发 data 事件。对于控制上传非常有用
【socket.resume()】
调用 pause() 后想恢复读取数据
【socket.setTimeout(timeout[, callback])】
socket 闲置时间超过 timeout 毫秒后 ，将 socket 设置为超时。触发空闲超时事件时，socket 将会收到 'timeout'事件，但是连接不会被断开。用户必须手动调用 end() 或 destroy() 这个socket。
如果 timeout = 0, 那么现有的闲置超时会被禁用。可选的 callback 参数将会被添加成为 'timeout' 事件的一次性监听器
【socket.setNoDelay([noDelay])】
禁用纳格（Nagle）算法。默认情况下 TCP 连接使用纳格算法，在发送前他们会缓冲数据。将 noDelay 设置为 true 将会在调用 socket.write() 时立即发送数据。noDelay 默认值为 true
【socket.setKeepAlive([enable][, initialDelay])】
禁用/启用长连接功能，在发送第一个在闲置socket上的长连接probe之前，可选地设定初始延时。默认false
设定initialDelay（毫秒），来设定收到的最后一个数据包和第一个长连接probe之间的延时。将 initialDelay 设为0，将会保留默认（或者之前）的值。默认值为0
【socket.address()】
操作系统返回绑定的地址，协议族名和服务器端口。返回的对象有 3 个属性，比如{ port: 12346, family: 'IPv4', address: '127.0.0.1' }
【socket.remoteAddress】
远程的 IP 地址字符串
【socket.remoteFamily】
远程IP协议族字符串
【socket.remotePort】
远程端口，数字表示
【socket.localAddress】
远程客户端正在连接的本地IP地址，字符串表示
【socket.localPort】
本地端口地址，数字表示
【socket.bytesRead】
接收的字节数
【socket.bytesWritten】
发送的字节数
【事件lookup】
在解析域名后，但在连接前，触发这个事件。对 UNIX sokcet 不适用
err {Error | Null} 错误对象
address {String} IP 地址。
family {String | Null} 地址类型【事件connect】
当成功建立 socket 连接时触发、
【事件data】
{Buffer object}当接收到数据时触发。参数 data 可以是 Buffer 或 String
当 Socket 触发一个 'data' 事件时，如果没有监听器，数据将会丢失
【事件end】
当 socket 另一端发送 FIN 包时，触发该事件
【事件timeout】
当 socket 空闲超时时触发，仅是表明 socket 已经空闲。用户必须手动关闭连接
【事件drain】
当写缓存为空得时候触发。可用来控制上传
【事件error】
错误发生时触发
【事件close】
had_error {Boolean} 如果 socket 传输错误，为 true当 socket 完全关闭时触发。参数 had_error 是 boolean，它表示是否因为传输错误导致 socket 关闭
【服务器】
//server.js
var net = require('net') ;
var server = net.createServer(function(socket) {
socket.write("Hi!\n");
socket.on("data", function(data) {
console.log(data.toString());
});
socket.on("end", function() {
console.log('有客户机下线了！！！');
});
socket.on('error', function() {
console.log('发生意外错误！！！');
});
}) ;
server.listen(8080) ;【客户机】
//client.js
var net = require('net') ;
var client = net.connect({port: 8080},function(){
client.name = '客户机1';
client.write(client.name + ' 上线了！\n');
client.end(client.name + ' 下线了！\n');
client.on("data", function(data) {
console.log(data.toString());
});
});
【服务器】
//chatServer.js
var net = require('net');
var i = 0;
//保存客户机
var clientList = [];
var server = net.createServer(function(socket) {
socket.name = '用户' + (++i);
socket.write('【聊天室提示】欢迎' + socket.name + '\n');
//更新客户机数组
clientList.push(socket);
function showClients(){
console.log('【当前在线用户】：');
for(var i=0;i<clientList.length;i++) {
console.log(clientList[i].name);
}
}
showClients();
socket.on("data", function(data) {
//把当前连接的客户机的信息转发到其他客户机
for(var i=0;i<clientList.length;i++) {
if(socket !== clientList[i]) {
clientList[i].write('【' + socket.name + '】：' + data);
}
}
});
socket.on("close", function() {
//当前客户机下线时，将其从客户机数组中移除
clientList.splice(clientList.indexOf(socket), 1);
showClients();
});
socket.on('error', function(err) {
console.log(socket.name + '退出');
});
});
server.listen(8080) ;【客户机】
//chatClient.js
var net = require('net');
process.stdin.resume();
process.stdin.setEncoding('utf8');
var client = net.connect({port: 8080},function(){
console.log('【本机提示】登录到聊天室');
process.stdin.on('data',function(data){
client.write(data);
})
client.on("data", function(data) {
console.log(data.toString());
});
client.on('end', function() {
console.log('【本机提示】退出聊天室');
process.exit();
});
client.on('error', function() {
console.log('【本机提示】聊天室异常');
process.exit();
});
});
更多编程相关知识，请访问：编程入门！！
위 내용은 nodejs의 net 모듈에 대한 간략한 토론의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
