如何在RabbitMQ上进行非阻塞？

Question

我是RabbitMQ的新手.我刚开始昨天.我发送和消费的东西很少见.我注意到的是他们的文档,甚至我读过的文章中的大多数都正在实现订阅部分,他们正在循环它以从队列中获取消息.我怎样才能使它成为事件驱动的？我想要完成的是当一个消息被发送到一个队列时,它将向接收者发出事件并对它做一些事情.也许就像显示消息一样.

非常感谢您的回复.

最好的祝福,

Answer 1

应该使用EventingBasicConsumer.我在我的网站上有一个例子,它显示了如何使用EventingBasicConsumer使用RabbitMQ事件

基本上它只是一个新的消费者,它暴露了一个Received事件,所以你不需要阻止.

Answer 2

一些示例使用这种循环样式，因为它更易于解释和理解。

您想使用IModel.BasicConsume而不是BasicGet. 有关示例（搜索订阅和消费），请参阅API 指南。