RabbitMQ 中怎么获取队列当前消息数量与消费者状态

夜瑶吖_7276

夜瑶吖_7276

2026-08-10

705人浏览

原创

可通过rabbitmq管理插件的web ui、http api或rabbitmqctl命令行工具查看队列消息数(ready/unacked)和消费者状态;web ui最直观,api适合监控集成,rabbitmqctl适用于本地快速检查,且消息数与消费者状态受消费确认、断连、ttl等实时影响。

rabbitmq 中怎么获取队列当前消息数量与消费者状态

可以通过 RabbitMQ 的管理插件提供的 HTTP API 或 Web UI 直接查看队列的消息数量和消费者状态,无需编写额外代码;命令行工具 rabbitmqctl 也能快速获取这些信息。

使用 Web UI 查看队列消息数与消费者状态

RabbitMQ 自带的管理界面是最直观的方式。启用管理插件后(默认未启用),访问 http://localhost:15672,登录后进入 Queues 标签页:

  • 每行显示一个队列,Ready 列即为当前等待被消费的消息数(未被取走)
  • Unacked 是已投递给消费者但尚未确认(ack)的消息数
  • Total = Ready + Unacked(部分版本还显示 Messages 总计)
  • Consumer 列显示当前连接的消费者数量,点击队列名称可看到详细消费者列表(含 IP、通道、标签、预取值等)

调用 HTTP API 获取实时数据

适合集成到监控或运维脚本中。基础 API 地址为 http://<host>:15672/api/queues</host>,支持按 vhost 和 queue 名过滤:

  • 获取所有队列:curl -u user:pass http://localhost:15672/api/queues
  • 获取指定队列详情:curl -u user:pass "http://localhost:15672/api/queues/%2F/my_queue"(%2F 是 URL 编码的 `/`,表示默认 vhost)
  • 返回 JSON 中关键字段:messages_ready、messages_unacknowledged、consumers

使用 rabbitmqctl 命令行查看

适用于服务器本地快速检查,无需网络或浏览器:

  • 列出所有队列及其消息数和消费者数:rabbitmqctl list_queues name messages_ready messages_unacknowledged consumers
  • 只查某个队列:rabbitmqctl list_queues name messages_ready messages_unacknowledged consumers | grep my_queue
  • 查看消费者详情(含连接信息):rabbitmqctl list_consumers

注意几个常见细节

消息数量不是静态值,受发布、消费、确认、拒绝、TTL 等行为实时影响:

  • Ready 消息在消费者 basic.consume 后、未 basic.ack 前会移入 Unacked
  • 若消费者断连且未设置 no_ack=true,Unacked 消息会重回 Ready 状态(前提是 channel 未关闭)
  • 队列设置了 x-max-length 或消息设了 TTL,可能导致 Ready 数量“不增反减”
  • 消费者状态中的 prefetch_count 影响一次最多拉取多少条未确认消息,间接影响 Unacked 值

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

java rabbitmq

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.02.23

604

5

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

2026.01.28

948

20

RabbitMQ使用教程合集
RabbitMQ使用教程合集

RabbitMQ使用教程合集整理 RabbitMQ 基础教程、消息队列开发案例、生产者消费者、交换机与队列实战内容。

2026.05.20

184

15

RabbitMQ集群部署指南
RabbitMQ集群部署指南

RabbitMQ集群部署指南聚合 RabbitMQ 集群部署、高可用架构、镜像队列、故障恢复、监控与运维优化内容。

2026.05.20

137

12

RabbitMQ Docker实战指南
RabbitMQ Docker实战指南

RabbitMQ Docker实战指南提供 RabbitMQ Docker 镜像部署、Docker Compose、Kubernetes Operator 与云原生实践教程。

2026.05.20

142

10

Playwright 测试失败怎么办
Playwright 测试失败怎么办

Playwright测试失败专题汇集超时、定位器匹配、浏览器提前关闭、依赖与插件配置、文件上传、SSL及Docker启动等故障文章,并介绍通过截图、报告和Trace定位错误。

2026.10.21

20

15

Playwright 页面操作指南
Playwright 页面操作指南

Playwright页面操作专题汇集元素定位、点击与输入、等待响应、多页面切换、Iframe、事件监听及文件处理的已审核文章,便于按操作场景查阅示例与常见问题。

2026.10.21

0

16

Playwright 入门教程
Playwright 入门教程

Playwright入门专题汇集测试框架安装、VS Code配置、录制脚本、编写首个用例、运行调试及查看报告的已审核文章,帮助初学者搭建端到端测试流程。

2026.10.21

0

16

OpenJDK JVM参数怎么调优
OpenJDK JVM参数怎么调优

Java应用运行缓慢,如何调整JVM参数?本专题介绍OpenJDK JVM性能调优的基本流程,涵盖性能指标确认、运行数据采集、内存配置和垃圾回收分析,帮助你先定位瓶颈,再通过对照测试验证效果,避免直接套用参数而影响应用稳定性。

2026.10.16

120

10

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
dev.java 官方:Learn Java
dev.java 官方:Learn Java

共0课时 | 0人学习

Java JDBC数据库连接官方教程
Java JDBC数据库连接官方教程

共0课时 | 0人学习