如何持续获取RabbitMQ队列的消息计数？

你遇到的问题是因为queue.method.message_count只是首次声明队列时返回的静态快照，不会自动更新队列的实时状态。以下两种方案可以实现持续获取消息数：

方案1：通过AMQP客户端定期查询队列状态 #

利用queue_declare方法的passive=True参数，仅查询现有队列的状态而不创建队列，每次调用都会从RabbitMQ服务器获取最新的消息数。以Python的pika库为例：

import pika
import time

# 建立连接
conn = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = conn.channel()

# 先确保队列已存在（首次执行）
channel.queue_declare(queue='your_queue_name')

while True:
    # 被动查询队列，获取最新状态
    queue_info = channel.queue_declare(queue='your_queue_name', passive=True)
    current_count = queue_info.method.message_count
    print(f"当前队列消息数：{current_count}")
    time.sleep(1)  # 按需调整查询间隔

方案2：调用RabbitMQ Management API #

通过HTTP请求定期访问RabbitMQ的管理API，直接获取队列的实时数据，适合监控类场景。同样以Python为例：

import requests
import time

# 配置信息
auth = ('guest', 'guest')  # 默认用户名密码
vhost = '%2F'  # 默认虚拟主机URL编码为%2F
queue_name = 'your_queue_name'
api_url = f'http://localhost:15672/api/queues/{vhost}/{queue_name}'

while True:
    resp = requests.get(api_url, auth=auth)
    if resp.status_code == 200:
        queue_data = resp.json()
        current_count = queue_data['messages']
        print(f"当前队列消息数：{current_count}")
    time.sleep(1)

两种方案的核心都是主动发起查询，因为RabbitMQ不会主动推送队列状态变化给客户端，必须定期请求才能拿到最新数据。

内容的提问来源于stack exchange，提问作者dmitry123321