如何在RabbitMQ上进行非阻塞
本文关键字：RabbitMQ | 更新日期: 2023-09-27 18:29:33
我是RabbitMQ的新手。我昨天刚开始上班。我在发送和消费东西方面做得很少。我注意到，在他们的文档中，甚至在我读过的文章中，他们中的大多数人都在以循环的方式实现订阅部分，以从队列中获取消息。我如何使它成为事件驱动的？我想实现的是，当一条消息被发送到队列时，它会向接收方引发事件并对其进行处理。也许就像显示消息一样。
非常感谢你的回复。
致问候，
应使用EventingBasicConsumer。我的网站上有一个例子，展示了如何使用EventingBasicConsumer 使用RabbitMQ事件
基本上，它只是一个公开Received事件的新消费者，所以您不需要阻止。
有些示例使用这种循环样式，因为它更容易解释和理解。
您希望使用IModel.BasicConsume而不是BasicGet。有关示例（搜索订阅和消费），请参阅API指南。