在RabbitMQ的如何消费多个消息或使用特定密钥读取队列中交换的所有消息或所有邮件?(In Rab

2019-10-19 15:47发布

我想消费从特定的队列或与给定键的特定交换多个消息。

这样的情况是如下:

出版商发布消息1在队列1个出版商发布消息2在队列1个出版商发布消息3在队列1个出版商发布消息4在队列2出版商发布消息5在队列2 ..消费者消费来自队列1 GET [消息1,消息2的消息,消息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的任务)使用铲到队列内容传送到一个扇出交换和直接从这种交换中使用消息直接从队列中消耗。 你得到所有连接消费者的所有消息。 :)



文章来源: In RabbitMQ how to consume multiple message or read all messages in a queue or all messages in exchange using specific key?