我有一个小应用程序,我在其中侦听来自 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客户端有问题?