如何在RabbitMQ上实现无阻塞？

Question

我是RabbitMQ的新手。我刚从昨天开始。我没有发送和消费东西的高峰。我注意到的是他们的文档，甚至我阅读过的大多数文章都是以一种循环方式实现订阅部分，以便从队列中获取消息。我怎样才能让它成为事件驱动？我想要完成的是当一条消息被发送到一个队列中时，它将会引发并发送给接收者并对其进行处理。也许就像显示消息一样。

非常感谢您的回复。

最好的问候，

Answer 1

一些例子使用了一个循环的风格，因为它更容易解释和理解。您想使用IModel.BasicConsume而不是BasicGet。有关示例，请参见API Guide（搜索订阅和消费）。

Answer 2

应使用EventingBasicConsumer。我在我的网站上有一个例子，显示它是如何使用的RabbitMQ Events using EventingBasicConsumer

基本上它只是一个新的使用者公开接收事件，因此您不需要阻止。