Tiếp tục công việc hàng đợi sau khi nhân viên NodeJS khởi động lại trên Heroku

Question

Vì vậy, tôi có thiết lập khá đơn giản trên Heroku. Tôi đang sử dụng RabbitMQ để xử lý các công việc trong nền. Thiết lập của tôi bao gồm tập lệnh nút chạy hàng ngày bằng cách sử dụng Trình lập lịch Heroku bổ trợ. Các kịch bản lệnh thêm các công việc vào hàng đợi, nhân viên lần lượt, tiêu thụ chúng và ủy quyền chúng vào một mô-đun riêng để xử lý.

Vấn đề bắt đầu sau khi tôi nhận được một SIGTERM trường hợp Heroku khởi ngẫu nhiên theo thời gian, trước khi khởi động lại ví dụ.

Vì một số lý do, sau khi cá thể được khởi động lại, nhân viên không bao giờ được sao lưu lại. Chỉ khi tôi khởi động lại thủ công bằng cách thực hiện heroku ps:scale worker=0 và heroku ps:scale worker=1 Nhân viên tiếp tục sử dụng các công việc đang chờ xử lý.

Dưới đây là công nhân của tôi:

// 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); 

Answer 1

Phương pháp close() trên jackrabbit đối tượng takes a callback, bạn nên tránh thoát quá trình này cho đến khi kết thúc:

function shutdown() { 
    logger.log({type: 'info', msg: 'shutting down'}); 
    queue.close(function (e) { 
     process.exit(e ? 1 : 0); 
    }); 
}