我们如何从 RabbitMQ 队列中获取实时消息而不会在 .NET 中出现任何延迟？

Question

我已经编写了代码来从RabbitMQ 队列中获取消息，并通过添加任务调度程序每 5 分钟执行一次该程序。

但是，这不是实时处理。它有 5 分钟的延迟。

我想让它实时处理。就像有人在RabbitMQ Queue 中添加消息一样，.NET 程序应该立即选择它进行进一步处理。

任何指针都将不胜感激。

Answer 1

我猜你不是在谈论真正的实时，而是尽可能快地获取消息。

这是通过在 RabbitMQ 中使用 EventingBasicConsumer 来完成的

var consumer = new EventingBasicConsumer(model);
consumer.Received += (ch, ea) =>
    {
       try
       {
            var body = ea.Body;
            var message = Encoding.UTF8.GetString(body);

        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            throw;
        }
    };
channel.BasicConsume(queueName, false, consumer);