rabbitmq - 在RabbitMQ中，如何使用特定的 key 消费多条消息或读取队列中的所有消息或交换的所有消息？

Question

我想从特定队列或具有给定 key 的特定交换中使用多条消息。

所以场景如下:

发布者通过队列 1 发布消息 1
发布者通过队列 1 发布消息 2
发布者通过队列 1 发布消息 3
发布者通过队列 2 发布消息 4
发布者通过队列 2 发布消息 5
..
消费者消费来自队列 1 的消息
一次获取 [message 1, message 2, message 3] 并在一个回调中处理它们

listen_to(queue_name , num_of_msg_to_fetch or all, function(messages){
//do some stuff with the returned list
});

消息不会同时到来，就像事件一样，我想将它们收集在队列中，打包并发送给第三方。

我也读了这篇文章:

http://rabbitmq.1065348.n5.nabble.com/Consuming-multiple-messages-at-a-time-td27195.html

谢谢

Answer 1

不要直接从队列中消费，因为队列遵循循环算法(AMQP 授权)
使用 shovel 将队列内容传输到扇出交换并直接从该交换使用消息。您可以在所有连接的消费者之间获得所有消息。 :)