我有一个baconjs用于保存的信息流mongoose。这是代码：
function main() {
db.once('open', function(callback) {
console.log('db connection successs');
console.log('stremaing page ' + page);
var stream = readSite(page);
stream.onValue(function(article) {
try {
article = toArticleModel(article);
} catch (e) {
console.error(e);
}
article.save(function(err, article) {
if (err) {
console.error('Save Error: ' + err);
} else {
console.log('saved ' + article.publishedDate + " " + article.author.name + " " + article.title);
}
});
stream.onError(function(err) {
console.error('Stream Error: ' + err);
});
stream.onEnd(function() {
console.log('stream ended closing in 15 seconds..');
setTimeout(function() {
db.close();
}, 15 * 1000);
});
});
});
流结束后onEnd，我想关闭数据库连接并退出nodejs程序。我认为一旦流结束，我应该等待一段时间，以便将最新值保存到数据库。所以我用setTimeout了15秒钟再使用db.close。
问题是，日志stream ended closing in 15 seconds..在标准输出中记录了50-60次，为什么？这是退出此类程序的好方法吗？
要添加的stream.onEnd监听器里面的stream.onValue。这意味着您将在每次onValue触发时添加侦听器。您需要将事件侦听器添加到其他事件侦听器之外，以便仅将它们添加一次。
有多种方法可以处理异步迭代，以确保在关闭数据库之前保存了所有项目值（实际上，跳过该步骤实际上可以使您摆脱这一步）。
// initialize savingArticles to 0
savingArticles++;
article.save(function (err, article) {
savingArticles--
if (streamEnded && !savingArticles)
db.close();
stream.onEnd(function () {
if (!savingArticles)
db.close();
else
streamEnded = true;
如果当前未保存文章且流已结束，则这将关闭数据库。如果流在当前正在保存文章的同时结束，则应在保存该文章后关闭数据库。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句