RabbitMq使用者未处理消息

希卡·马赫什瓦里(Shikhar Maheshwari)

我已经使RabbitMQ成为使用C#.NET编写的控制台应用程序的使用者。它被编程为永久监听队列,并且只要它在队列中找到消息就对其进行处理。使用者平均每秒处理35条消息。使用者被安排为在任务调度程序中的系统启动时运行。消费者可以运行3-4天。但是,尽管队列中有消息,但它们仍继续运行,但不处理任何消息。当使用者停止并再次启动时,它将再次开始正确处理消息。但是,当您手动重新启动时,数百万条消息已排队。有人可以帮我解释这种异常行为。我也有其他队列,这些队列自几个月以来一直在运行,而且一直都没有停止过。

请求快速响应。在此先感谢专家。

ErAcube

我建议您看一下使用者代码,它可能正在运行,但是卡在RabbitMQ异常中。可以正常运行3-4天听起来很奇怪。

我有类似的问题,即使用者不使用队列中的消息,因为我使用“ RabbitMQ.Client.QueueingBasicConsumer”使消息出队,并且尽管使用者正在运行,但突然关闭队列,但它在System.IO.EndOfStreamException中。我正在使用“ RabbitMQ.Client.Events.EventingBasicConsumer”,它已帮助我解决了该问题。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

RabbitMQ重试消息而不从使用者发布

来自分类Dev

Rabbitmq使用者获取不同路由密钥的消息

来自分类Dev

RabbitMQ-如何为新使用者保存消息

来自分类Dev

RabbitMQ使用者在收到MQTT消息时失败

来自分类Dev

RabbitMQ使用者未收到该消息

来自分类Dev

如何让所有使用者处理未决消息?

来自分类Dev

如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

来自分类Dev

如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

来自分类Dev

RabbitMQ为断开连接的使用者保留消息多长时间?

来自分类Dev

当没有使用者时,获取消息以保留在RabbitMQ中

来自分类Dev

Java / Spring-从使用者内部发送RabbitMQ消息

来自分类Dev

RabbitMQ-将消息发送到队列中的特定使用者

来自分类Dev

RabbitMQ渠道闲置问题| 如何恢复未确认的AMQP消息| Javaclient使用者

来自分类Dev

RabbitMQ多个使用者订阅相同的队列并获得相同的消息

来自分类Dev

如何保证RabbitMQ中具有多个使用者的队列的任务订单处理?

来自分类常见问题

如何使用2个具有相同组ID的使用者来处理消息?

来自分类Dev

优先处理RabbitMQ消费者消息的使用

来自分类Dev

删除的队列未重新定义,使用者停止处理消息

来自分类Dev

Rabbit MQ取消确认消息未返回到队列以供使用者再次处理

来自分类Dev

我如何让RabbitMQ使用者仅接收一条消息而不会超时并发送agan?

来自分类Dev

使用nodeJS在RabbitMQ中删除使用者

来自分类Dev

如何使用Pyspark Streaming模块实现RabbitMQ使用者?

来自分类Dev

如何使用Docker运行RabbitMQ使用者-NodeJS

来自分类Dev

RabbitMQ固定答复和使用者配置

来自分类Dev

PHP RabbitMQ使用者:预取1

来自分类Dev

在PHP上如何取消RabbitMQ中的使用者?

来自分类Dev

如何为ServiceStack RabbitMQ使用者创建多个线程?

来自分类Dev

闲置90秒后,RabbitMQ使用者连接消失

来自分类Dev

PHP RabbitMQ使用者:预取1

Related 相关文章

  1. 1

    RabbitMQ重试消息而不从使用者发布

  2. 2

    Rabbitmq使用者获取不同路由密钥的消息

  3. 3

    RabbitMQ-如何为新使用者保存消息

  4. 4

    RabbitMQ使用者在收到MQTT消息时失败

  5. 5

    RabbitMQ使用者未收到该消息

  6. 6

    如何让所有使用者处理未决消息?

  7. 7

    如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

  8. 8

    如何在.Net中与不同类型的使用者一起使用RabbitMq消息?

  9. 9

    RabbitMQ为断开连接的使用者保留消息多长时间?

  10. 10

    当没有使用者时,获取消息以保留在RabbitMQ中

  11. 11

    Java / Spring-从使用者内部发送RabbitMQ消息

  12. 12

    RabbitMQ-将消息发送到队列中的特定使用者

  13. 13

    RabbitMQ渠道闲置问题| 如何恢复未确认的AMQP消息| Javaclient使用者

  14. 14

    RabbitMQ多个使用者订阅相同的队列并获得相同的消息

  15. 15

    如何保证RabbitMQ中具有多个使用者的队列的任务订单处理?

  16. 16

    如何使用2个具有相同组ID的使用者来处理消息?

  17. 17

    优先处理RabbitMQ消费者消息的使用

  18. 18

    删除的队列未重新定义,使用者停止处理消息

  19. 19

    Rabbit MQ取消确认消息未返回到队列以供使用者再次处理

  20. 20

    我如何让RabbitMQ使用者仅接收一条消息而不会超时并发送agan?

  21. 21

    使用nodeJS在RabbitMQ中删除使用者

  22. 22

    如何使用Pyspark Streaming模块实现RabbitMQ使用者?

  23. 23

    如何使用Docker运行RabbitMQ使用者-NodeJS

  24. 24

    RabbitMQ固定答复和使用者配置

  25. 25

    PHP RabbitMQ使用者:预取1

  26. 26

    在PHP上如何取消RabbitMQ中的使用者?

  27. 27

    如何为ServiceStack RabbitMQ使用者创建多个线程?

  28. 28

    闲置90秒后,RabbitMQ使用者连接消失

  29. 29

    PHP RabbitMQ使用者:预取1

热门标签

归档