讲师中心 微信公众号
AI工具推荐 视频效率加速

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

夜瑶吖_7276

夜瑶吖_7276

发布时间:2026-08-10 14:06:32

|

725人浏览过

|

来源于php中文网

原创

可通过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 值

热门AI工具

更多
讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

相关专题

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

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

624

2024.02.23

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

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

968

2026.01.28

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

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

184

2026.05.20

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

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

137

2026.05.20

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

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

142

2026.05.20

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

0

2026.10.22

Gradle Wrapper配置教程
Gradle Wrapper配置教程

本专题介绍Gradle Wrapper的基本作用,涵盖文件组成、生成方法、版本配置和任务调用,帮助你理解项目如何使用指定的Gradle版本,减少不同开发环境带来的构建差异。

0

2026.10.22

Golangci-lint检查器使用教程
Golangci-lint检查器使用教程

本专题整理Golangci-lint常用Linters的用途与配置方法,覆盖错误处理、无效代码、安全、复杂度、命名和依赖检查,帮助项目合理选规则。

0

2026.10.22

Gradle怎么构建Java项目
Gradle怎么构建Java项目

本专题介绍Gradle Java项目构建方法,涵盖Java插件配置、依赖声明、源码编译、测试执行和打包检查,帮助你理解各阶段的任务关系,逐步完成项目构建。

0

2026.10.22

热门下载

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

精品课程

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

共0课时 | 0人学习

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

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn