node.js 需要太多的 TCP 套接字

node.js requires too many TCP sockets

本文关键字:TCP 套接字 太多 js node      更新时间:2023-09-26

我对node.js很陌生(通常是服务器问题的初学者)。

我设法运行我的节点.js应用程序并将其放在我的虚拟服务器(Linux 8.0)上。

问题是节点.js打开了很多TCP套接字。 一段时间后,允许的套接字数量耗尽,服务器崩溃。 我目前必须手动停止并重新启动节点进程以防止这种情况。 重新启动将重置 TCP 套接字。

我需要找到解决此问题的方法,因为手动重新启动它不是一个长期的解决方案,特别是如果访问者数量会增加并且我可能需要每 12 小时重新启动一次它(这是不切实际的)。

我可能在编码中做错了什么,但我目前不知道我可以优化什么。 我很高兴它甚至有效。 代码的哪一部分正在创建所有这些TCP连接? 我该如何解决这个问题?

我的节点文件/应用程序执行以下操作:

  • 向公开和/或私人聊天发送/发送消息。
  • 发送/发出游戏邀请(游戏类型不重要)
  • 如果邀请接受邀请,则两个"客户"将被发送到同一个房间和游戏开始

节点服务器.js

var socket = require( 'socket.io' );
var express = require( 'express' );
var http = require( 'http' );
var app = express();
var server = http.createServer( app );
var io = socket.listen( server );
// handle incoming connections from clients
io.sockets.on( 'connection', function( client ) {
  // Message Emit for match invite
  client.on( 'sendmatchinvite', function( data ) {
    console.log( 'Match invite for '+data.opponent+' from '+data.sender);
    client.broadcast.emit('sendmatchinvite', { tmpmatch:data.tmpmatch, recepient: data.opponent, sender: data.sender } );
  });
  // Answer of invite 
  client.on( 'checkinviteanswer', function( data ) {
    console.log( 'Invitation '+data.answer+' from '+data.id+' in '+data.room);
    client.broadcast.to(data.room).emit('checkinviteanswer', { host:data.host } );
  });
  // Register Room
  client.on('room', function(room) {
    console.log( 'Client joined the room: '+room);
    client.join(room);
  });
  // Score Emit for online games
  client.on( 'score', function( data ) {
    console.log( 'New Score for "'+data.game+'" (from '+data.player+') : ' + data.score + ' (Undo='+data.undo+') in room '+data.room);
    client.broadcast.to(data.room).emit('score', { game:data.game, score: data.score, undo: data.undo, player: data.player } );
  });
  // Message Emit for private chat
  client.on( 'privatemessage', function( data ) {
    console.log( 'New Message for "'+data.recepient+'" (from '+data.sender+') : ' + data.text);
    client.broadcast.emit('privatemessage', { text:data.text, recepient: data.recepient, sender: data.sender } );
  });
  // Message Emit for Player Room (all)
  client.on( 'openmessage', function( data ) {
    console.log( 'New Message for "Player Room" (from '+data.senderId+') : ' + data.text);
    client.broadcast.emit('openmessage', { text:data.text, senderId:data.senderId, senderAvatar:data.senderAvatar, senderName:data.senderName, senderAvg:data.senderAvg, senderCam:data.senderCam, senderTimestamp:data.senderTimestamp, senderTime:data.senderTime } );
  });
});     
server.listen( 8080 );

如果我做一个lsof -ni -P来查看连接,节点确实有很多行

COMMAND     PID         USER   FD   TYPE     DEVICE SIZE/OFF NODE NAME
...
node      13855         root  273u  IPv4 33761866321      0t0  TCP 83.256.77.109:8080->84.60.76... (ESTABLISHED)
node      13855         root  275u  IPv4 33781428883      0t0  TCP 83.256.77.109:8080->94.197.121...(ESTABLISHED)
node      13855         root  276u  IPv4 33937034956      0t0  TCP 83.256.77.109:8080->79.195.169... (ESTABLISHED)
node      13855         root  278u  IPv4 33971290522      0t0  TCP 83.256.77.109:8080->111.254.157... (ESTABLISHED)
node      13855         root  279u  IPv4 33198279063      0t0  TCP 83.256.77.109:8080->91.48.115... (ESTABLISHED)
...

编辑 1

应该注意我使用php页面。 在所有需要节点应用程序的php页面上,我都与节点服务器建立了连接。

var socket = io.connect( 'http://example.com:8080' );
socket.on('connect', function( data ) { });

我不确定这是否是正确的方法,因为在每次刷新页面时,连接都会关闭并重新建立。

首先,确保正确配置服务器。现代 Linux 具有保守的默认值,这些默认值未针对高同时连接进行优化。这里有一些提示:

可以连接多少个套接字?

其次,确保你有办法"踢"用户。例如,有人可能会在咖啡店使用手机或笔记本电脑进行连接,然后关闭设备。如果没有流量,TCP 连接可以保持打开状态数小时或数天。 如果您不主动检测它们,它们将慢慢切断所有有效的 TCP 连接。