如何阻止抛出的错误沿链向下传播? 它显示在我的catch()
块中,但它不会停止并导致服务器崩溃并出现未捕获的异常。
我将其作为节点 cron 作业(节点 cron(的一部分运行为:
var cronJob = require('cron').CronJob;
var cron = require('../lib/cron')
var c = new cronJob('* * * * * *', function() {
console.log('Cron starting');
mycode.run();
}, function() {
console.log('Cron executed');
}, true);
c.start();
在我的cron中.js
module.exports = {
run: function() {
return job.getAndStore().catch(function(e) {
// This prints but it keeps on going so to speak - it doesn't 'catch', just notifies me
console.log('ERROR', e);
});
}
};
控制台转储:
Cron starting
ERROR [TypeError: undefined is not a function]
Cron starting
Uncaught Exception
[TypeError: undefined is not a function]
TypeError: undefined is not a function
我必须这样做,我知道不太正确:
try {
run();
} catch(e) {
console.log('Now it stops')
}
run()
是一些没有任何承诺支持的 cron 库的一部分,所以我将其包装在函数中以调用它。
编辑 由于我认为我的问题与后续调用有关,因此我认为这与我如何处理 2+ 次调用上的 Mongo 连接有关:
// Create a Mongo connection
Job.prototype.getDb = function(id) {
var self = this;
return new P(function(resolve, reject) {
if (!self.db) {
return Mongo.connectAsync(self.options.connection)
.then(function(c) {
self.db = c;
debug('Got new connection');
resolve(c);
});
}
debug('Got existing connection');
resolve(self.db);
});
};
// Fetch stuff
Job.prototype.getAndStore = function(c) {
return this.getDb().then(function() {
throw new Error('Boom');
});
};
您的catch
回调仅在第一次执行。您在第二次运行 cron 作业时收到未捕获的异常,看起来您的job.getAndStore()
在那里没有返回被拒绝的承诺,而是同步throw
。它不应该,它应该总是返回一个承诺。
您可以使用 Bluebirds Promise.try
自动捕获此类异常并将其转换为承诺拒绝。或者您将getAndStore
函数包装在 Promise.method
中:
var safeGetAndStore = Promise.method(job.getAndStore.bind(job));
module.exports = {
run: function() {
return safeGetAndStore().catch(function(e) {
console.log('ERROR', e);
});
}
};
在您的特定情况下,问题是您的job
确实缓存了db
连接并在它已经可用时返回了该连接 - 但您需要使用 .then
方法返回承诺。您应该简单地缓存承诺本身:
Job.prototype.getDb = function(id) {
if (!this.db) {
this.db = Mongo.connectAsync(self.options.connection);
return this.db;
};
使用done
,至少如果蓝鸟正确实现它,它将按预期工作。
catch(..)
只是then(null, ..)
的别名,它是承诺转换器,它为进一步处理创建了另一个承诺。
因此,以下内容应该适合您:
module.exports = {
run: function() {
return job.getAndStore().done(null, function(e) {
// This prints but it keeps on going so to speak - it doesn't 'catch', just notifies me
console.log('ERROR', e);
});
}
};