JAVA中怎么获取rabbitmq消息总数

本篇文章为大家展示了JAVA中怎么获取rabbitmq消息总数,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。

成都创新互联专注于企业全网整合营销推广、网站重做改版、开原网站定制设计、自适应品牌网站建设、H5建站成都商城网站开发、集团公司官网建设、成都外贸网站建设公司、高端网站制作、响应式网页设计等建站业务,价格优惠性价比高,为开原等各大城市提供网站开发制作服务。

首先需要创建一个连接,配置文件注入相关的值,然后设置连接的相关信息,创建链接。

导入的包是使用:

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消息总数,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联行业资讯频道。


网页名称:JAVA中怎么获取rabbitmq消息总数
文章地址:http://myzitong.com/article/pchehc.html