Rabbit MQ NodeJS 中的串行处理

Question

我正在使用 RabbitMQ 处理我项目中的一些作业。 目前，如果我发送 5 个工作，可以说

Job1
Job2
Job3
Job4
Job5

所有作业都被交付到队列中，但是如果 Job1 需要 5 秒完成，而 Job2 需要 2 秒完成，则执行顺序变为 喜欢

Job5
Job1 etc.,

我有没有办法让所有这些作业仅在 RabbitMQ 接收器中的前一个作业完成后才执行（执行流程如 Job1、Job2、Job3、Job4、Job5）？

作业执行（根据 Dave 的要求）

var amqp = require('amqplib');

amqp.connect('amqp://localhost').then(function(conn) {
  process.once('SIGINT', function() { conn.close(); });
  return conn.createChannel().then(function(ch) {

    var ok = ch.assertQueue('hello', {durable: false});

    ok = ok.then(function(_qok) {
      return ch.consume('hello', function(msg) {

        //JOB HERE

      }, {noAck: true});

    });

    return ok.then(function(_consumeOk) {
      console.log(' [*] Waiting for messages. To exit press CTRL+C');
    });
  });
}).then(null, console.warn);

谢谢， 巴兰

Answer 1

我认为您将 RabbitMQ 服务器与应用程序逻辑混淆了。简短的回答是，不，您不能保证消息处理的顺序。

为了解决您的澄清问题，队列并不关心您的应用程序如何从中提取。队列仅向您的应用程序提供消息。如何处理它们取决于您（例如串行、并行等）。我认为，如果您只计划串行处理，那么使用消息队列没有多大意义，因为您获得了消息服务器的所有缺点而没有任何好处。或许您可以多描述一下您的应用程序？

有关更多详细信息，请参阅我在message order of delivery 的其他答案。