NodeJS + Redis + WebSocket 内存管理？

Question

我有一个托管 WebSocket 服务器的 NodeJS。 WebSocket 从 Redis 重新分发消息。

整行是，我有一些 python 脚本在 Redis 中推送一些数据，之后 NodeJS 是 WebSocket，它将 Redis 新输入的数据读取到连接的客户端。我的问题是 NodeJs 总是占用内存，过了一会儿它就突然停止了。

我不知道我的问题是什么，因为我的代码很简单。

我不需要我的 WebSocket 从连接的客户端接收消息，因为我只需要向它们推送数据，但需要推送大量数据。

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

var socket = new server({
httpServer: http.createServer().listen(443),
keepalive: false
});

client.subscribe("attack-map-production");
socket.on('request', function(request) {
var connection = request.accept(null, request.origin);

connection.on('message', function(message) {
    console.log(message);
            client.on("message", function(channel, message){
                    connection.send(message);
            });
});

connection.on('close', function(connection) {
    console.log('connection closed');
});
});

我希望在不占用服务器上所有内存的情况下完成这项工作，并且可能会更快，但我认为它已经足够快了。

也许 NodeJS 不适合这种工作？

感谢任何帮助。 谢谢。

2016 年 11 月 8 日更新
根据下面提供的信息，我已经“更新”了我的代码。问题依然存在，我会继续四处寻找答案......但我真的没有得到这个。

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


var socket = new server({
httpServer: http.createServer().listen(443),
keepalive: false
});

client.subscribe("attack-map-production");

socket.on('request', function(request) {
var connection = request.accept(null, request.origin);

    client.on("message", function(channel, message){
            connection.send(message);
    });

connection.on('close', function(connection) {
    console.log('connection closed');
});
});

2016 年 11 月 16 日更新

这是我的新代码：

var io = require('socket.io').listen(443);
var sub = require('redis').createClient();

io.sockets.on('connection', function (sockets) {
    sockets.emit('message',{Hello: 'World!'});
    sub.subscribe('attack-map-production'); // Could be any patterni

    sockets.on('disconnect', function() {
            sub.unsubscribe('attack-map-production');
    });
});

sub.on('message', function(channel, message) {
    io.sockets.json.send(message);
});

即使是这段代码，也让 nodejs 以 100% 甚至更多的 CPU 运行，它开始变得非常缓慢，直到一切都停止。

我的数据的完整流程，是一个python脚本将数据推送到Redis，并通过我的订阅将我的数据通过webSocket和Socket.io推送回浏览器。

这么简单，怎么会这么慢？我就是不明白。

Answer 1

client = redis.createClient();

看看这一行，每次调用变量 client 时，都会在 node 内创建一个 redis client 实例，并且永远不会关闭它。因此，如果您收到 10000 个套接字“请求”，您还将拥有 10000 个 redis 实例。

完成对redis的写入或读取后，您需要调用命令client.quit()

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


var socket = new server({
httpServer: http.createServer().listen(443),
keepalive: false
});

client.subscribe("attack-map-production");

socket.on('request', function(request) {
var connection = request.accept(null, request.origin);

    client.on("message", function(channel, message){
            connection.send(message);
    });

client.quit();  // MISSING LINE

connection.on('close', function(connection) {
    console.log('connection closed');
});
});

我也注意到了这段代码

httpServer: http.createServer().listen(443)

端口 443 用于 https ！因此，如果您使用的是安全连接，则需要调用模块 https 而不是 http，像这样

var socket = new server({
httpServer: https.createServer().listen(443),
keepalive: false
});

希望对你有帮助！

Answer 2

也许 NodeJS 不适合这种工作？

如果 node 是用来做某事的，那就是这个。 I/O流和读/写是节点异步的主要优势。

你在什么样的服务器上运行这个？在一个太小的 EC2 实例中，您可能会遇到一些内存问题。

否则就是泄漏。这有点难以追踪。

代码是小思想。

我会删除任何 console.log 以防万一。

connection.on('message', function(message) {
    console.log(message);
            client.on("message", function(channel, message){
                    connection.send(message);
            });
});

这部分感觉很可疑，两个同名的变量，一个未使用的变量，很麻烦，我真的不明白为什么你必须监听连接消息才能等待redis消息。