java - 暂时停止消费 RabbitMQ 消息并稍后恢复

Question

我使用Java的rabbitmq-client ( https://mvnrepository.com/artifact/com.rabbitmq/amqp-client )，我需要实现以下场景:

• 在接收 Rabbit 消息时，如果我怀疑所有等待的数据无法放入内存，我可能需要暂停特定队列的 Rabbitmq 消耗。
• 处理完一些消息后，我需要再次为以下一组消息打开消费。
• 根据需要重复。

使用 amqp-client Java 库实现 RabbitMQ 队列监听的暂停/恢复的最佳方法是什么？

Answer 1

您没有提及您使用哪种方法来消费消息，所以我假设您正在使用 basicConsume订阅队列中的消息。

如that document提到，您可以使用 basicCancel 停止从队列中消费。然后，当您希望重新开始时，您可以使用 basicConsume。

请务必使用 basicQos 设置合理的预取计数。