公司使用的是rabbitMQ，需要做监控预警的job去监控rabbitMQ里面的堆积消息个数，如何使用rabbitMQ获取监控的队列里面的队列消息个数呢？
公司主营业务：成都网站制作、做网站、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。成都创新互联公司是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。成都创新互联公司推出仁和免费做网站回馈大家。
首先需要创建一个连接，配置文件注入相关的值，然后设置连接的相关信息，创建链接。
导入的包是使用：
import com.rabbitmq.client
@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();
//设置ip，port，用户名和秘密
factory.setHost(host);
factory.setPort(port);
factory.setUsername(username);
factory.setPassword(password);
//创建链接
Connection connection = factory.newConnection();
//创建信道
Channel channel = connection.createChannel();
//创建一个type=direct 持久化的 非自动删除的交换器
channel.exchangeDeclare(EXCHANGE_NAME, "direct", true, false, null);而我使用的是直接创建一个DeclareOK：
String []queues = queueNames.split(",");
for(String queue : queues){
DeclareOk declareOk = channel.queueDeclarePassive(queue);
//获取队列中的消息个数
int num = declareOk.getMessageCount();
if(num > 100) {
//当队列数超过100的时候，进行操作
}
}这样就可以根据获取到每个队列的堆积数，然后进行应急处理。
说个题外话：
@Value("${business.consumerQueue}")
private String queueNames;
String []queues = queueNames.split(",");在配置文件中配置：business.consumerQueue=nameQueue,numberQueue,phoneQueue
那么获取到的那个字符串数组queues就是为String[3]，其中分别是上述的三个队列。
这样做的话就可以不用改代码，遵循封闭-开放原则，不用改原来的代码，只需要修改配置文件中的代码，用 “,” 相隔开，获取到需要操作的队列名字数组。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持创新互联。
分享标题：JAVA获取rabbitmq消息总数过程详解
文章转载：
http://cdkjz.cn/article/pcgdpi.html
