我使用Java的rabbitmq-client(https://mvnrepository.com/artifact/com.rabbitmq/amqp-client),我需要实现以下场景:
使用amqp-client Java库实现从RabbitMQ队列中监听暂停/恢复的最佳方法是什么?
您没有提到您使用哪种方法来使用消息,因此我假设您使用basicConsume
订阅队列中的消息。
正如that document所提到的,你可以使用basicCancel
停止从队列中消费。然后,当您希望重新开始时,您将使用basicConsume
。
请务必使用basicQos
设置合理的预取计数。