私は Node.js の内部の仕組みにあまり詳しくありませんが、私の知る限り、関数呼び出しが多すぎると「最大呼び出しスタック サイズを超えました」というエラーが発生します。
リンクをたどるスパイダーを作成していますが、ランダムな数の URL をクロールした後にこれらのエラーが発生し始めました。これが発生した場合、ノードはスタック トレースを提供しませんが、再帰エラーがないことは確かです。
requestを使用して URL をフェッチし、 cheerioを使用してフェッチした HTML を解析し、新しいリンクを検出しました。スタック オーバーフローは常に Cheerio 内で発生します。Cheerio をhtmlparser2に交換すると、エラーが消えました。Htmlparser2 は、ドキュメント全体を解析してツリーを構築するのではなく、開いているタグごとにイベントを発行するだけなので、はるかに軽量です。
私の理論は、チェリオがスタック内のすべてのメモリを使い果たしたということですが、これが可能かどうかはわかりませんか?
これが私のコードの簡略化されたバージョンです(読み取り専用で、実行されません):
var _ = require('underscore');
var fs = require('fs');
var urllib = require('url');
var request = require('request');
var cheerio = require('cheerio');
var mongo = "This is a global connection to mongodb.";
var maxConc = 7;
var crawler = {
concurrent: 0,
queue: [],
fetched: {},
fetch: function(url) {
var self = this;
self.concurrent += 1;
self.fetched[url] = 0;
request.get(url, { timeout: 10000, pool: { maxSockets: maxConc } }, function(err, response, body){
self.concurrent -= 1;
self.fetched[url] = 1;
self.extract(url, body);
});
},
extract: function(referrer, data) {
var self = this;
var urls = [];
mongo.pages.insert({ _id: referrer, html: data, time: +(new Date) });
/**
* THE ERROR HAPPENS HERE, AFTER A RANDOM NUMBER OF FETCHED PAGES
**/
cheerio.load(data)('a').each(function(){
var href = resolve(this.attribs.href, referer); // resolves relative urls, not important
// Save the href only if it hasn't been fetched, it's not already in the queue and it's not already on this page
if(href && !_.has(self.fetched, href) && !_.contains(self.queue, href) && !_.contains(urls, href))
urls.push(href);
});
// Check the database to see if we already visited some urls.
mongo.pages.find({ _id: { $in: urls } }, { _id: 1 }).toArray(function(err, results){
if(err) results = [];
else results = _.pluck(results, '_id');
urls = urls.filter(function(url){ return !_.contains(results, url); });
self.push(urls);
});
},
push: function(urls) {
Array.prototype.push.apply( this.queue, urls );
var url, self = this;
while((url = self.queue.shift()) && this.concurrent < maxConc) {
self.fetch( url );
}
}
};
crawler.fetch( 'http://some.test.url.com/' );