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

Question

我是 node.js 的新手(通常是服务器问题的初学者)。

我成功地运行了我的 node.js 应用程序并将其放到我的虚拟服务器 (Linux 8.0) 上。

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

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

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

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

• 向公开和/或私有(private)聊天发送/发出消息。
• 发送/发出游戏邀请(游戏类型不重要)
• 如果邀请接受邀请，两个“客户”都会被送到同一个房间和游戏开始

nodeServer.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 来查看连接，确实有很多行按 Node

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 页面。在所有需要 Node 应用程序的 php 页面上，我连接到 Node 服务器。

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

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

Answer 1

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

How many socket connections possible?

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