如何用php获取rabbitmq指定队列中的未处理消息数量

PHP扩展选用的是php-amqp

希望实现的是,在php中能获取到指定消息队列中的未被领取走的消息数量(包括Un-ack的消息)。

在命令行下执行: XXX/rabbitmqctl list_queues可以返回该数据

我想知道php下是否有对应方法可以获取该值?

@modi 的答案补全代码:
截图

阅读 18.3k
4 个回答

declare一个队列,置AMQP_PASSIVE标志位,就不会影响服务端状态,并返回消息计数。

$conn = new AMQPConnection();
//...
$queue = new AMQPQueue($conn);
$queue->setFlags(AMQP_PASSIVE);
$messageCount = $queue->declare($queueName); // <- 这里
//...
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题