如何限制rabbitmq中消费消息的数量？

Posted 2023-01-21

我在rabbitmq项目中与amqplib和node合作。

我使用队列在服务之间传递作业消息。 其中一个服务使用这些消息，执行某些过程并将结果返回到另一个队列。

有时队列会保存大量消息，并且服务会尝试一次性消耗它们，从而导致进程（服务）崩溃。

如何限制频道/服务可以处理的消息数量？ 我想到了一个自定义解决方案，持有全球限制，但我宁愿将它作为最后的手段......

答案

从您的问题来看，这并不完全清楚，但似乎您希望限制服务消耗消息的方式，而不是队列保留的消息数量。如果这种理解是正确的，那么你需要的是prefetch_count。更多文档：https://www.rabbitmq.com/consumer-prefetch.html

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://localhost', function(err, conn) 
conn.createChannel(function(err, ch) 
    var q = 'task_queue';

    ch.assertQueue(q, durable: true);
    ch.prefetch(1);                // THIS SHOULD SOLVE YOUR PROBLEM
    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q);
    ch.consume(q, function(msg) 
      var secs = msg.content.toString().split('.').length - 1;

      console.log(" [x] Received %s", msg.content.toString());
      setTimeout(function() 
        console.log(" [x] Done");
        ch.ack(msg);
      , secs * 1000);
    );
  );
);

代码来源：https://www.rabbitmq.com/tutorials/tutorial-two-javascript.html