NodeJS+Redis+WebSocket内存管理

Question

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

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

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

我不需要我的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();

看看这一行，每次调用变量客户端时，都会在节点内创建一个redis客户端的实例，并且永远不会关闭它。因此，如果您收到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不适合这种工作？

若节点是为某事而设的，那个就是这个。I/O流和读/写是节点异步的主要优点。

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

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

代码是微小的想法。

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

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

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