所以我在Heroku上有一个相当简单的设置。我正在使用RabbitMQ处理后台作业。我的设置包含一个使用Heroku Scheduler插件每天运行的节点脚本。脚本将作业添加到队列中,然后工作人员使用它们并将它们委托给单独的模块进行处理。
在我收到Heroku不时随机启动的SIGTERM事件之后,在重新启动实例之前,问题就开始了。
出于某种原因,在实例重新启动后,worker 永远不会再次恢复。只有当我通过执行手动重新启动它heroku ps:scale worker=0
并且heroku ps:scale worker=1
工作人员继续使用挂起的作业时。
这是我的工人:
// worker.js
var throng = require('throng');
var jackrabbit = require('jackrabbit');
var logger = require('logfmt');
var syncService = require('./syncService');
var start = function () {
var queue = jackrabbit(process.env.RABBITMQ_BIGWIG_RX_URL || 'amqp://localhost');
logger.log({type: 'msg', msg: 'start', service: 'worker'});
queue
.default()
.on('drain', onDrain)
.queue({name: 'syncUsers'})
.consume(onMessage)
function onMessage(data, ack, nack) {
var promise;
switch (data.type) {
case 'updateUser':
promise = syncService.updateUser(data.target, data.source);
break;
case 'createUser':
promise = syncService.createUser(data.source);
break;
case 'deleteUser':
promise = syncService.deleteUser(data.target);
}
promise.then(ack, nack);
}
function onDrain() {
queue.close();
logger.log({type: 'info', msg: 'sync complete', service: 'worker'});
}
process.on('SIGTERM', shutdown);
function shutdown() {
logger.log({type: 'info', msg: 'shutting down'});
queue.close();
process.exit();
}
};
throng({
workers: 1,
lifetime: Infinity,
grace: 4000
}, start);