这里有两个问题。
我认为这是由于缺乏反压力。
您的脚本仅向Redis发送1M发布命令,但不处理对这些命令的任何答复(因此,它们仅由node_redis丢弃)。因为它从不等待任何答复,所以脚本将为所有这些命令在内存中累积大量上下文。node_redis需要保持上下文以跟踪命令,并关联Redis命令和答复。Node.js排队命令的速度比系统将这些命令传送到Redis,对其进行处理,构建回复并将回复传送回node.js的速度要快。因此,上下文正在增长,它代表了大量的内存。
如果要将内存消耗保持在可接受的水平,则需要降低代码速度,以便有机会让node.js处理Redis答复。例如,以下脚本也处理1M个项目,但它将它们作为1000个项目的批次发布,并等待每1000个项目的答复。因此,它只占用很少的内存(上下文最多包含1000个待处理的命令)。
var redis = require("redis"),
publisher = redis.createClient();
function loop( callback ) {
var count = 0;
for ( i=0 ; i < 1000; ++i ) {
publisher.publish("rChat", i, function(err,rep) {
if ( ++count == 1000 )
callback();
});
}
}
function loop_rec( n, callback ) {
if ( n == 0 ) {
callback();
return;
}
loop( function() {
loop_rec( n-1, callback );
});
}
function main() {
console.log("Hello");
loop_rec(1000, function() {
console.log("stopped sending messages");
setTimeout(function(){publisher.end();},1000);
return;
});
}
publisher.ping(main)
setTimeout(function() {
console.log("Keeping console alive");
}, 1000000);
通常,它不能。作为所有C / C ++程序,node.js使用内存分配器。释放内存后,它不会释放到系统,而是释放到内存分配器。通常,内存分配器无法将未使用的内存返还给系统。请注意,这不是泄漏,因为如果程序执行新的分配,则内存将被重用。
编写实际上可以向系统释放内存的C / C 程序通常涉及设计 自定义内存分配器。很少有C / C 程序可以做到这一点。最重要的是,node.js包括一个带有v8的垃圾收集器,因此它应该对内存释放策略施加其他约束。