Rabbitmq使用单个同步调用检索多个消息

Question

有没有办法使用单个同步调用接收多条消息？

当我知道队列中有N条消息(N可能是小于10的小值)时,我应该能够做类似channel.basic_get(String queue,boolean autoAck,int numberofMsg)的操作.我不想向服务器发出多个请求.

Answer 1

basic.get不幸的是, RabbitMQ 不支持多条消息,如文档中所示.检索多个消息的首选方法是使用basic.consume,它会将消息推送到客户端,避免多次往返.acks是异步的,因此您的客户端不会等待服务器响应.basic.consume还有一个好处是,如果客户端断开连接,允许RabbitMQ重新传递消息,这是basic.get无法做到的.这可以关闭以及设置no-ack为true.

设置basic.qos prefetch-count将随时设置要推送到客户端的消息数.如果客户端没有等待消息(将立即返回),客户端库往往会阻塞可选的超时.