我有一个应用程序,其中我从服务器顺序下载mp3文件,暂时将它们存储在我的服务器上,然后直接向客户端流式传输它们,如下所示:
function downloadNextTrack(){
var request = http.get('http://mp3server.com', function(response){
response.on('data', function(data) {
fs.appendFile('sometrack.mp3', data, function (err) {});
});
response.on('end', function(){
streamTrack('sometrack.mp3');
}
});
};
var clients = []; // client response objects are pushed to this array when they request the stream through a route like /stream.mp3
var stream;
function streamTrack(track){
stream = fs.createReadStream(track);
stream.on('data', function(data){
clients.forEach(function(client) {
client.write(data);
});
});
stream.on('end', function(){
downloadNextTrack(); // redoes the same thing with another track
}
};
显然,这段代码创建了许多缓冲区,而操作系统没有释放它们。当我运行'free -M'命令时,得到的结果如下(在运行该应用程序约4个小时后):
total used free shared buffers cached
Mem: 750 675 75 0 12 180
-/+ buffers/cache: 481 269
Swap: 255 112 143
'缓冲区'下面的数字不断上升(以及缓存内存),操作系统显然不会收回那180mb,直到最终我的应用程序耗尽内存并在我尝试生成小进程以验证轨道的比特率、采样率、id3信息等时崩溃。
我使用了很多不同的工具进行诊断(如memwatch和nodetime),以找出是否存在内存泄漏,但实际上没有,V8内存堆以及Node RSS变化+/-10mb,但在大部分时间里保持恒定,而操作系统的可用内存越来越少(当Node进程启动时,我有大约350MB的可用内存)。
我在某个地方读到过,由Node分配的缓冲区实例可以直接访问原始内存,所以V8对它们无法控制(这与我从V8堆中没有获得内存泄漏的事实相符),问题是,我需要一种方法来摆脱这些旧缓冲区。这可能吗?或者我必须每5个小时重新启动我的应用程序(或更糟糕,购买更多RAM!)?
PS.我在Ubuntu 10.04上运行Node v0.8.16。
setTimeout(function (){streamTrack('somefile');}, 0);
。 它将消除“递归”错误(我知道,有点延迟的答案)。 - Ivan Seidel