在之前的will ACKed之前，RabbitMQ STOMP有没有办法停止消费消息？

Question

我在我的项目中使用了RabbitMQ Web-STOMP，它对我来说非常好，但它有一个问题。当消费者订阅一个队列时，它会立即获得队列中的所有消息。在我的例子中，一个消息任务可能会花费很多时间，只有在前一个任务完成时，消费者才有必要从队列中获取下一个消息。

一切正常，当发布在消费者订阅之后开始时，但是当队列中已经有消息时，第一个订阅的消费者将获得所有消息，而其他消费者将保持免费。是否有类似node-amqp的queue.shift()方法仅在previous为ACKed时使用next message？

Answer 1

(您使用的是哪个客户端？)

您的问题的答案是basic_qos，请参见amqp reference并搜索basic.qos

在c#应用编程接口中，您将执行以下操作：

int prefetch = 10;

IModel channel = connection.CreateModel(); //where connection is IConnection
channel.basic_qos(0, prefetch, false);

预取大小可以用来告诉rabbitmq服务器在确认之前要向消费者发送多少消息。如果设置了NO-ACK选项，则忽略预取大小。

请记住，设置此值可能会对性能产生潜在影响，请查看this。