RabbitMq 消费者不处理消息
RabbitMq Consumer not processing messages
我已经为 RabbitMQ 创建了一个消费者，作为一个用 C#.NET 编写的控制台应用程序。它被编程为永久侦听队列，每当它在队列中找到一条消息时，它就会处理它。消费者平均每秒处理 35 条消息。消费者在系统启动时在任务调度程序中被调度到 运行。消费者 运行 罚款 3 - 4 天。但是，他们继续 运行ning 但不处理任何消息，尽管队列中有消息。当消费者停止并再次启动时，它会再次开始正确处理消息。但是，当您手动重新启动时，数百万条消息会排队。有人可以帮我解释一下这种异常行为吗？我还有其他队列，几个月来一直 运行ning 一直没有停止。
请求及时回复。在此先感谢专家。
我建议您查看消费者代码，它可能 运行 但卡在 RabbitMQ 异常中。它可以正常运行 3-4 天，这听起来很奇怪。
我有类似的问题，消费者不使用队列中的消息，因为我使用 "RabbitMQ.Client.QueueingBasicConsumer" 使消息出队，当队列突然关闭时，尽管消费者是 运行 但它在 System.IO.EndOfStreamException。我正在使用 "RabbitMQ.Client.Events.EventingBasicConsumer"，它帮助我解决了问题。
我已经为 RabbitMQ 创建了一个消费者，作为一个用 C#.NET 编写的控制台应用程序。它被编程为永久侦听队列，每当它在队列中找到一条消息时，它就会处理它。消费者平均每秒处理 35 条消息。消费者在系统启动时在任务调度程序中被调度到 运行。消费者 运行 罚款 3 - 4 天。但是，他们继续 运行ning 但不处理任何消息，尽管队列中有消息。当消费者停止并再次启动时，它会再次开始正确处理消息。但是，当您手动重新启动时，数百万条消息会排队。有人可以帮我解释一下这种异常行为吗？我还有其他队列，几个月来一直 运行ning 一直没有停止。
请求及时回复。在此先感谢专家。
我建议您查看消费者代码，它可能 运行 但卡在 RabbitMQ 异常中。它可以正常运行 3-4 天，这听起来很奇怪。
我有类似的问题，消费者不使用队列中的消息，因为我使用 "RabbitMQ.Client.QueueingBasicConsumer" 使消息出队，当队列突然关闭时，尽管消费者是 运行 但它在 System.IO.EndOfStreamException。我正在使用 "RabbitMQ.Client.Events.EventingBasicConsumer"，它帮助我解决了问题。