RabbitMQ C# API 基于事件的消息消费 [英] RabbitMQ C# API Event based Message Consumption
本文介绍了RabbitMQ C# API 基于事件的消息消费的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
while (true)
{
BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue();
IBasicProperties properties = e.BasicProperties;
byte[] body = e.Body;
Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body));
ch.BasicAck(e.DeliveryTag, false);
}
这就是我们通过订阅检索消息时所做的事情..我们使用 While 循环是因为我们希望消费者连续收听..如果我想让它甚至基于..那是当新消息到达队列时那时只有消费者应该消费该消息..或任何此类类似事件..
This is what we do when we Retrieve Message by subscription..We use While Loop because we want Consumer to listen Continously..what if i want to make this even based..that is when a new message arrives in the queue at that time only Consumer should Consume the message..or on any such similar event..
推荐答案
将 RabbitMQ.Client.Events.EventingBasicConsumer
用于事件消费者而不是阻塞消费者.
use the RabbitMQ.Client.Events.EventingBasicConsumer
for a eventing consumer instead of a blocking one.
这篇关于RabbitMQ C# API 基于事件的消息消费的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文