问题描述
我想使用给定密钥从特定队列或特定交换中消耗多条消息.
I want to consume multiple messages from specific queue or a specific exchange with a given key.
因此情况如下:
发布者在队列1上发布消息1发布者在队列1上发布消息2发布者在队列1上发布消息3发布者在队列2上发布消息4发布者在队列2上发布消息5..使用者使用队列1中的消息同时获得[消息1，消息2，消息3]，并在一次回叫中处理它们
Publisher publish message 1 over queue 1Publisher publish message 2 over queue 1Publisher publish message 3 over queue 1Publisher publish message 4 over queue 2Publisher publish message 5 over queue 2..Consumer consume messages from queue 1get [message 1, message 2, message 3] all at once and handle them in one call back
listen_to(queue_name , num_of_msg_to_fetch or all, function(messages){
//do some stuff with the returned list
});
消息不是同时发出的，就像事件一样，我想将它们收集在队列中，打包并发送给第三方.
the messages are not coming at the same time, it is like events and i want to collect them in a queue, package them and send them to a third party.
我也阅读了这篇文章:
http://rabbitmq. 1065348.n5.nabble.com/Consuming-multiple-messages-at-a-time-td27195.html
谢谢
推荐答案
当队列遵循轮询算法(AMQP要求)时，不要直接从队列中使用使用铲将队列内容传输到扇出交换机，并直接从此交换机使用消息.您会在所有连接的使用者之间获得所有消息. :)
Don't consume directly from the queue as queues follow round robin algorithm(an AMQP mandate)Use shovel to transfer the queue contents to a fanout exchange and consume messages right from this exchange. You get all messages across all connected consumers. :)
这篇关于在RabbitMQ中，如何使用多条消息使用多条消息或读取队列中的所有消息，或者交换所有消息以使用特定密钥?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！