主要介绍了JAVA获取rabbitmq消息总数过程详解，公司使用的是rabbitMQ，需要做监控预警的job去监控rabbitMQ里面的堆积消息个数，如何使用rabbitMQ获取监控的队列里面的队列消息个数呢,需要的朋友可以参考下
在Java中，获取RabbitMQ消息总数的过程涉及与RabbitMQ服务器建立连接、创建通道、声明队列以及查询队列状态。以下是一个详细的步骤解析：
1. **建立连接**: 需要通过`ConnectionFactory`类来创建一个连接工厂，并设置RabbitMQ服务器的相关配置，包括主机名（host）、端口（port）、用户名（username）和密码（password）。这些值通常从配置文件中读取，如Spring Boot项目中的`application.properties`或`application.yml`。
```java
@Value("${spring.rabbitmq.host}")
private String host;
@Value("${spring.rabbitmq.port}")
private Integer port;
@Value("${spring.rabbitmq.username}")
private String username;
@Value("${spring.rabbitmq.password}")
private String password;
ConnectionFactory factory = new ConnectionFactory();
factory.setHost(host);
factory.setPort(port);
factory.setUsername(username);
factory.setPassword(password);
```
2. **创建连接和通道**: 使用`ConnectionFactory`创建一个新的连接`Connection`，然后在这个连接上创建一个通道`Channel`。通道是与RabbitMQ服务器进行通信的主要接口。
```java
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
```
3. **声明交换器和队列**: 在RabbitMQ中，消息是通过交换器路由到队列的。这里假设已有一个直接类型的持久化交换器，可以通过`exchangeDeclare`方法声明。如果只需要查询队列消息数，可以声明为被动模式（`queueDeclarePassive`），这将不会创建新的队列，而是检查队列是否存在并返回其状态。
```java
// 声明交换器
channel.exchangeDeclare(EXCHANGE_NAME, "direct", true, false, null);
// 声明队列并获取消息数（如果队列已存在）
String []queues = queueNames.split(",");
for (String queue : queues) {
DeclareOk declareOk = channel.queueDeclarePassive(queue);
int num = declareOk.getMessageCount();
if (num > 100) {
// 当队列消息数超过100时，执行相应的操作
}
}
```
4. **队列监控**: 通过`queueDeclarePassive`方法，我们可以获取到队列的状态，包括消息数量。如果队列中的消息数超过预设阈值（例如100），则可以触发相应的预警或处理逻辑。
5. **配置文件管理**: 队列名称通常通过配置文件进行管理，如`business.consumerQueue`。这个属性可以是一个包含多个队列名称的逗号分隔字符串。在运行时，这个字符串被分割成一个字符串数组，这样就可以动态地添加或移除队列，而无需修改代码。
```java
@Value("${business.consumerQueue}")
private String queueNames;
String []queues = queueNames.split(",");
```
6. **封闭-开放原则**: 这种方式遵循了软件设计中的封闭-开放原则，即软件实体（类、模块、函数等）应该是可扩展的，但不可修改。在这里，可以通过修改配置文件来增加或减少监控的队列，而不需要改动代码，增强了系统的灵活性和可维护性。
总结，Java获取RabbitMQ消息总数的核心在于正确配置RabbitMQ连接，声明队列并使用`queueDeclarePassive`方法获取队列状态。同时，利用配置文件管理队列，实现系统对新队列的动态适应，使得监控和预警功能更加灵活高效。通过以上步骤，你可以轻松地在Java应用中实现对RabbitMQ队列消息数的实时监控。
