javascript - 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-08 更新
使用下面提供的信息，我已经“更新”了我的代码。问题仍然存在，我将继续四处寻找答案...但我真的没有得到这个。

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
});

希望对您有所帮助!