Node.js redis 订阅内存泄漏

Question

我是“服务器端 JS”的新手，找不到使用 node.js 和 Redis-Sub 进行长轮询的示例。

以下代码运行良好，但今天我注意到 RAM 使用量为 650MB，而代码仅使用了 6 天。

var http     = require('http'),
    redis    = require('redis'),
    client   = redis.createClient();

client.subscribe("example");

http.createServer(function (req, res) {

    res.setHeader('Access-Control-Allow-Origin', 'https://mywebsite.com');
    res.setHeader('Access-Control-Allow-Methods', 'GET');
    res.setHeader('Access-Control-Allow-Headers', 'X-Requested-With,content-type');
    res.setHeader('Access-Control-Allow-Credentials', true);

    res.writeHead(200, {'Content-Type': 'application/json'});

    client.on("message", function (channel, message) {

        res.end( JSON.stringify( message ) );

    });

}).listen(8080);

有人可以指出内存泄漏并解释一下吗？

我的 node.js 版本是：v0.10.21

Answer 1

“内存泄漏”来自代码client.on。您在请求/响应函数中调用它。 client.on 是一个发射器（参见 redis 源代码，index.js:111（截至今天的 npm 安装）），它使用

定义函数 on

在指定事件的侦听器数组末尾添加一个侦听器。 （Nodejs-Docs：1）

所以你不断向客户端添加"message"-functions。将client.on 移到此请求/响应-“循环”之外，它应该停止“泄漏”。

Answer 2

从逻辑上讲，您正在寻找类似以下的内容，所以从这里开始：

var http     = require('http'),
    redis    = require('redis'),
    client   = redis.createClient();

client.subscribe("example");

var responses = [];

client.on('message', function(channel, message) {
    var res;
    while (responses.length) {
        res = responses.pop();
        res.end(JSON.stringify(message));
    }
});

http.createServer(function (req, res) {

    res.setHeader('Access-Control-Allow-Origin', 'https://mywebsite.com');
    res.setHeader('Access-Control-Allow-Methods', 'GET');
    res.setHeader('Access-Control-Allow-Headers', 'X-Requested-With,content-type');
    res.setHeader('Access-Control-Allow-Credentials', true);

    res.writeHead(200, {'Content-Type': 'application/json'});

    responses.push(res);

}).listen(8080);

随着您继续收到尚未对消息和end()ed 满意的请求，您的内存需求将会增加，但除此之外，这里并没有很多事情发生。任何真正的内存泄漏都必须从组件模块中引入。

Answer 3

没错。我想我现在明白了，但是如果我错了，请纠正我：redis 客户端会定期发送更新，这些更新会准确说明其中包含哪些数据。 （因此，如果它永远不会改变，它将永远定期发送相同的消息。）使用当前代码，客户端可以向您的服务器发送请求，并接收 redis 服务器内容的更新。但是客户端必须等到下一次你的服务器从 redis 获取更新。

客户必须等待的事实感觉不对。我认为它应该立即发送从 redis 收到的最新更新的响应。这应该可以通过一些修改来实现：

var http     = require('http'),
    redis    = require('redis'),
    client   = redis.createClient();

var lastMessage = null;

client.subscribe("example");

client.on("message", function (channel, message) {

    lastMessage = message

});

http.createServer(function (req, res) {

    res.setHeader('Access-Control-Allow-Origin', 'https://mywebsite.com');
    res.setHeader('Access-Control-Allow-Methods', 'GET');
    res.setHeader('Access-Control-Allow-Headers', 'X-Requested-With,content-type');
    res.setHeader('Access-Control-Allow-Credentials', true);

    res.writeHead(200, {'Content-Type': 'application/json'});

    res.end( JSON.stringify( lastMessage ) );

}).listen(8080);

而且上面的代码也没有重复设置redis handler，所以应该不会泄露内存。

我可以看到的一个缺点是，如果客户端在节点收到 redis 的消息之前请求更新，它将收到null。在这种（可能是不寻常的）情况下，在回复之前等待 redis 可能会更好。

如果这让您感到困扰，您可以将res.end( JSON.stringify( lastMessage ) ); 行替换为“如果您已经收到redis 的消息，那么res.end( JSON.stringify( lastMessage ) );；否则，设置一个处理程序在redis 发送消息时执行此操作”。处理程序应该设置为只运行一次，然后被删除；您可以使用.once 而不是.on 来做到这一点。