查看rabbitmq消息堆积 java如何获取rabbitmq队列中消息数量？

java如何获取rabbitmq队列中消息数量？

这里是rabbitmq的消息确认机制：“为了保证消息不会丢失，rabbitmq支持消息确认机制。在接收和处理消息之后，客户机可以向rabbitmq发送一条ACK消息，告诉它消息可以被安全删除。如果客户端在发送ACK之前意外死亡，rabbitmq将消息传递给下一个使用者客户端。如果有多个客户机，则rabbitmq在传递消息时进行轮询。rabbitmq如何判断客户已经死亡？唯一的依据是客户端是否断开连接。没有超时机制，也就是说，客户端可以长时间地处理消息。只要连接没有断开，rabbitmq将始终等待ACK消息。“我现在面临的问题是：我有几个线程要从消息队列中获取数据，但是会有异常数据导致线程挂起，即“客户端在发送ack之前意外死亡”。Rabbitmq会将消息传递给下一个客户机，这样的异常数据会挂断我的所有线程。现在我想实现这个功能是的：如果异常数据导致进程挂起，我不会让rabbitmq把这个消息传递给下一个客户机，而是把它放到另一个地方或者单独处理它。我该如何实现这一点？

查看rabbitmq消息堆积 mq查看接收队列的消息 rabbitmq消息返回结果

版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。