socket.io + node.js 的内存泄漏

我的 Node.js 应用程序似乎存在内存泄漏。我很快就构建了它，而且我的 JavaScript 不太强大，所以这可能很容易。

我已经对它做了一些堆转储，它是字符串object？内存泄漏，速度约为每 5 分钟 1MB。我扩展了String，它实际上是String.Array？

Heap stack:

#!/usr/local/bin/node

var port = 8081;

var io = require('socket.io').listen(port),
sys = require('sys'),
daemon = require('daemon'),
mysql = require('mysql-libmysqlclient');

var updateq = "SELECT 1=1";
var countq = "SELECT 2=2";

io.set('log level', 2);


process.on('uncaughtException', function(err) {
  console.log(err);
});

var connections = 0;

var conn = mysql.createConnectionSync();
dbconnect();

io.sockets.on('connection', function(client){ 
  connections++;
  client.on('disconnect', function(){ connections--;  }) 
});

process.on('exit', function () {
    console.log('Exiting');
    dbdisconnect();
});

function dbdisconnect() {
     conn.closeSync();
}

function dbconnect() {
    conn.connectSync('leet.hacker.org','user','password');
}


function update() {
    if (connections == 0)
        return;
    conn.query(updateq, function (err, res) {
      if (err) {
        dbdisconnect();
        dbconnect();
        return;
      }
      res.fetchAll(function (err, rows) {
        if (err) {
          throw err;
        }
        io.sockets.json.send(rows);
      });
    });
}

function totals() {
    if (connections == 0)
        return;
        conn.query(countq, function (err, res) {
          if (err) {
        // Chances are that the server has just disconnected, lets try reconnecting
        dbdisconnect();
        dbconnect();
            throw err;
          }
          res.fetchAll(function (err, rows) {
            if (err) {
              throw err;
            }
        io.sockets.json.send(rows);
          });
        });

}

setInterval(update, 250);
setInterval(totals,1000);

setInterval(function() {
console.log("Number of connections: " + connections);
},1800000);



  daemon.daemonize('/var/log/epiclog.log', '/var/run/mything.pid', function (err, pid) {
    // We are now in the daemon process
    if (err) return sys.puts('Error starting daemon: ' + err);

    sys.puts('Daemon started successfully with pid: ' + pid);
  });

当前版本

function totals() {

        if (connections > 0)
        {
                var q = "SELECT query FROM table";

            db.query(q, function (err, results, fields) {
            if (err) {
                    console.error(err);
                    return false;
            }

            for (var row in results)
            {
                    io.sockets.send("{ ID: '" + results[row].ID + "', event: '" + results[row].event + "', free: '" + results[row].free + "', total: '" + results[row].total + "', state: '" + results[row]$
                    row = null;
            }


            results = null;
            fields = null;
            err = null;
            q = null;
            });
    }
}

仍然泄漏内存，但似乎仅在以下条件下发生：

• 从启动开始，没有客户端 -> 很好
• 第一个客户端连接 -> 良好
• 第二个客户端（即使第一个客户端断开连接并重新连接）-> 内存泄漏
• 停止所有连接 -> 好
• 1 个新连接（连接 = 1）-> 内存泄漏

帮自己一个忙并使用节点mysql https://github.com/felixge/node-mysql，它是一个纯 JavaScript 的 mysql 客户端，而且速度很快。除此之外，您应该使用异步代码来阻止 IO 在工作时被阻塞。使用async https://github.com/caolan/async图书馆将在这里为您提供帮助。它具有瀑布回调传递的代码等。

至于你的内存泄漏，它可能不是socket.io，虽然我已经几个月没有使用它了，但我有数千个并发连接并且没有泄漏内存，而且我的代码也不是最好的。

然而，有两件事。首先，您的代码无法读取。我建议考虑正确格式化代码（我为每个缩进使用两个空格，但有些人使用四个空格）。其次，每半小时打印一次连接数似乎有点愚蠢，当你可以这样做时：

setInterval(function() {
  process.stdout.write('Current connections: ' + connections + '     \r');
}, 1000);

The \r将导致该行被读回到该行的开头并覆盖那里的字符，这将替换该行并且不会产生大量的回滚。如果您选择将调试详细信息放入日志记录中，这将有助于调试。

您还可以使用process.memoryUsage()用于快速检查内存使用情况（或节点认为您正在使用多少内存）。