Ale*_*x C 7 memory-leaks memory-management node.js
我有一个RSS到MongoDB阅读器/刮刀,它运行的数据集大于我的系统有内存.当我遍历数据时,系统会变慢.我有理由相信这是因为我的内存不足.
我添加了一些调试信息并进行了一些更改,但我不知道如何读取调试输出中给出的信息.
这是一个调试输出示例(从它变得致命之前):
100 items
Memory: { rss: 11104256, // what is RSS?
vsize: 57507840, // what is VSIZE?
heapTotal: 4732352, // heapTotal?
heapUsed: 3407624 } // heapUsed?
200 items
Memory: { rss: 12533760,
vsize: 57880576,
heapTotal: 6136320,
heapUsed: 3541984 }
// what key numbers do I watch for?
// when do I reach 'situation critical'?
// how do I free up memory to prevent problems?
Run Code Online (Sandbox Code Playgroud)
此外,如果它有帮助,为了更好地说明,我已经包含了一些代码示例.我已经做出的一个改变是将所有require语句移到GrabRss函数之外.
var http = require('http');
var sys = require('sys');
var xml2js = require('xml2js');
var util = require('util');
var Db = require('../lib/mongodb').Db,
Conn = require('../lib/mongodb').Connection,
Server = require('../lib/mongodb').Server,
// BSON = require('../lib/mongodb').BSONPure;
BSON = require('../lib/mongodb').BSONNative;
GrabRss = function(grab, start) {
var options = {
host: 'www.example.com',
port: 80,
path: '/rss/'+grab+'/'+start
};
var data;
var items;
var checked = 0;
var len = 0;
GotResponse = function(res) {
var ResponseBody = "";
res.on('data', DoChunk);
res.on('end', EndResponse);
function DoChunk(chunk){
ResponseBody += chunk;
}
function EndResponse() {
//console.log(ResponseBody);
var parser = new xml2js.Parser();
parser.addListener('end', GotRSSObject);
parser.parseString(ResponseBody);
}
}
GotError = function(e) {
console.log("Got error: " + e.message);
}
GotRSSObject = function(r){
items = r.item;
//console.log(sys.inspect(r));
var db = new Db('rss', new Server('localhost', 27017, {}), {native_parser:false});
db.open(function(err, db){
db.collection('items', function(err, col) {
len = items.length;
if (len === 0) {
process.exit(0);
}
for (i in items) {
SaveItem(item[i], col);
}
});
});
}
SaveMovie = function(i, c) {
c.update({'id': i.id}, {$set: i}, {upsert: true, safe: true}, function(err){
if (err) console.warn(err.message);
if (++checked >= len) {
if (checked < 5000) {
delete data; // added since asking
delete items; // added since asking
console.log(start+checked);
console.log('Memory: '+util.inspect(process.memoryUsage()));
GrabRss(50, start+checked);
} else {
console.log(len);
process.exit(0);
}
} else if (checked % 10 == 0) {
console.log(start+checked);
}
});
}
http.get(options, GotResponse).on('error', GotError);
}
GrabRss(50, 0);
Run Code Online (Sandbox Code Playgroud)
阅读完这段代码后,我确实看到itemsGotRSSObject被声明为全局,因为它没有var前置它.
除此之外,我看不到其他明显的内存泄漏.一个很好的基本技术是添加一些打印语句来查看内存的分配位置,然后通过断言变量== null来检查内存要清理的位置.
node.js和v8的内存问题是它不能保证在任何时候都是垃圾收集而且afaik,你不能强制垃圾收集发生.您需要限制您正在使用的数据量以便轻松适应内存并提供一些错误处理(可能使用setTimeout或process.nextTick)以等待内存清理完毕.
给nextTick一个忠告 - 这是一个非常非常快速的通话.每个人都知道,Node.js在事件循环上是单线程的.使用nextTick将在下一个循环中逐字执行该函数 - 确保您不经常调用它,否则您将发现自己浪费周期.
而有关rss,vsize,heapTotal,heapUsed... vsize是的,你的进程正在使用和内存的整体尺寸rss是多少的是在实际的物理内存,而不是交换.heaptotal并heapUsed参考您无法控制的v8底层存储.您最关心的是vsize,但您也可以top在OS X上获取更多详细信息或使用Activity Monitor(任何人都知道*nix系统上的良好过程可视化工具?).