我已经使RabbitMQ成为使用C#.NET编写的控制台应用程序的使用者。它被编程为永久监听队列,并且只要它在队列中找到消息就对其进行处理。使用者平均每秒处理35条消息。使用者被安排为在任务调度程序中的系统启动时运行。消费者可以运行3-4天。但是,尽管队列中有消息,但它们仍继续运行,但不处理任何消息。当使用者停止并再次启动时,它将再次开始正确处理消息。但是,当您手动重新启动时,数百万条消息已排队。有人可以帮我解释这种异常行为。我也有其他队列,这些队列自几个月以来一直在运行,而且一直都没有停止过。
请求快速响应。在此先感谢专家。
我建议您看一下使用者代码,它可能正在运行,但是卡在RabbitMQ异常中。可以正常运行3-4天听起来很奇怪。
我有类似的问题,即使用者不使用队列中的消息,因为我使用“ RabbitMQ.Client.QueueingBasicConsumer”使消息出队,并且尽管使用者正在运行,但突然关闭队列,但它在System.IO.EndOfStreamException中。我正在使用“ RabbitMQ.Client.Events.EventingBasicConsumer”,它已帮助我解决了该问题。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句