如何在NodeJ上仅使用来自rabbit mq的一条消息

Question

我使用amqp.node库集成Rabbitmq到我的系统。

但是在消费者中，我想一次只处理一条消息，然后确认消息，然后从队列中消费下一条消息。

目前的代码是：

// Consumer
open.then(function(conn) {
  var ok = conn.createChannel();
  ok = ok.then(function(ch) {
    ch.assertQueue(q);
    ch.consume(q, function(msg) {
      if (msg !== null) {
        othermodule.processMessage(msg, function(error, response){
          console.log(msg.content.toString());
          ch.ack(msg);
        });
      }
    });
  });
  return ok;
}).then(null, console.warn);

ch.consume将一次处理通道中的所有消息，模块的功能在这里调用，其他模块不会在同一时间线执行。

我想等待othermodule函数完成，然后再使用队列中的下一条消息。

Answer 1

您需要设置一个预取值，如本示例所示：

https://github.com/squaremo/amqp.node/blob/master/examples/tutorials/rpc_server.js#L22

Answer 2

创建模型时，需要在模型上设置QOS。下面是我们在C#中的实现方式：

    var _model = rabbitConnection.CreateModel();
    // Configure the Quality of service for the model. Below is how what each setting means.
    // BasicQos(0="Dont send me a new message untill I’ve finshed",  _fetchSize = "Send me N messages at a time", false ="Apply to this Model only")
    _model.BasicQos(0, _fetchSize, false);
    var consumerTag = _model.BasicConsume(rabbitQueue.QueueName, false, _consumerName, queueingConsumer);

Answer 3

目前（2018年），我认为RabbitMQ团队可以选择这样做：

https://www.rabbitmq.com/tutorials/tutorial-two-javascript.html

ch.prefetch(1);

为了克服这个缺点，我们可以使用值为1的预取方法。这告诉RabbitMQ一次不要向工作进程发送多条消息。或者，换句话说，在工作进程处理并确认前一条消息之前，不要向其发送新消息。相反，它将把它分派给下一个还不忙的工作人员。