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

下面是RabbitMQ的消息确认机制：“为了确保消息不会丢失，RabbitMQ支持消息确认机制。客户端在接受到消息并处理完后，可以发送一个ack消息给RabbitMQ，告诉它该消息可以安全的删除了。假如客户端在发送ack之前意外死掉了，那么RabbitMQ会将消息投递到下一个consumer客户端。如果有多个consumer客户端，RabbitMQ在投递消息时是轮询的。RabbitMQ如何判断客户端死掉了？唯一根据是客户端连接是否断开。这里没有超时机制，也就是说客户端可以处理一个消息很长时间，只要没断开连接，RabbitMQ就一直等待ack消息。”我现在遇到的问题是这样的：我这边有几条线程去消息队列里取数据，但是会有异常数据导致线程挂掉，就是上边的“客户端在发送ack之前意外死掉了”，RabbitMQ会将消息投递到下一个consumer客户端，这样一条异常数据会把我的所有线程挂掉，我现在想实现这样的功能：如果有异常数据导致进程挂掉，那么我不让RabbitMQ将这条消息投递到下一个consumer客户端，而是放到另一个地方或者另外处理，请问该如何实现呢？

javamq大量数据怎么及时响应给客户端
javamq大量数据怎么及时响应给客户端
1、使用高性能的消息中间件，如Kafka，RabbitMQ等，提高消息传输的效率。
2、使用异步消息技术，采用消息队列的方式，将消息放入队列中，客户端可以立即收到消息，不用等待消息处理完成。
3、使用分布式消息中间件，将消息分发到不同的服务器上，以提高消息处理效率。
4、使用缓存技术，将消息缓存到内存中，以便快速响应客户端请求。
5、使用负载均衡技术，将消息分发到不同的服务器上，以提高消息处理效率。

JMS：Java Message Service，java消息服务，是一个消息服务的标准或者说是规范，允许应用程序组件基于JavaEE平台创建、发送、接收和读取消息。它使分布式通信耦合度更低，消息服务更加可靠以及异步性。
JMS是java的消息服务，JMS的客户端之间可以通过JMS服务进行异步的消息传输。

p2p：点对点发送，一个消息只能被消费一次
涉及：
消息队列（Queue）
发送者（Sender）
接收者（Receiver）
每个消息都被发送到一个特定的队列，接收者从队列中获取消息。队列保留着信息，直到它们被消费或超时。
示意图：p2p示意图
特点：

Pub/Sub：发布订阅，一个消息可以被消费多次
涉及角色：
主题（Topic）
发布者（Publisher）
订阅者（Subscriber）
客户端将消息发送到主题。多个发布者将消息发送到Topic，系统将这些消息传递给多个订阅者。
示意图：Pub/Sub示意图
特点：

MQ：消息中间件（MOM：Message Orient middleware），消息队列
作为系统间通信的必备技术，低耦合、可靠传输、流量控制、最终一致性
实现异步消息通信

Apache下
完全支持Java的JMS协议
消息模式：1、点对点 2、发布订阅

Erlang语言实现的开源的MQ中间件，支持多种协议
主要的通信协议是AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用协议的一个开放标准，为面向消息的中间件设计。

Apache下开源项目
高性能分布式消息队列，一般海量数据传输，大数据部门用
单机吞吐量：10w/s

阿里 贡献给了Apache
参考了Kafka实现基于Java 消息中间件

消息传输最快

RabbitMQ是一个开源的AMQP实现，服务端用Erlang语言编写，支持多种客户端，如：Python、Ruby、NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。
消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。

涉及角色：

可以基于Docker安装RabbitMQ，记住其端口：
15672：网页版可视化服务器数据
5672：客户端连接的端口号

点对点消息
一个消息只能消费一次
只需要队列就可以，不需要交换机
消息发送者和消息接收者者可以不同时在线

RabbitMQ特色就在于Exchange，主要有以下类型：
fanout：只要有消息就转发给绑定的队列，不会进行消息的路由判断
direct：会根据路由匹配规则，将消息发送到指定队列中，注意路由规则不支持特殊字符
topic：会根据路由匹配规则，将消息发送到指定队列中，注意路由规则支持特殊字符，比如： #

---