0

我有一个小应用程序,我在其中侦听来自 PG 数据库的 NOTIFY 事件并将它们广播到 socketcluster 通道。由于某种原因,应用程序的内存使用量不断增长。

pg.connect(connectionString, function(err, client) {
      client.on('notification', function(msg) {
            var payload = msg.payload.split(";;");

            if ( payload[0] == "CREATE") {
                var tchannel = socket.subscribe(msg.channel + "_creates");
                tchannel.on('subscribe', function(){
                    tchannel.publish(msg.payload, function(err, ackData){
                        tchannel.unsubscribe();
                        tchannel.off();
                        tchannel.destroy();
                    });
                });
            }
      });

});

我自己没有正确清理,还是socketcluster客户端有问题?

4

0 回答 0