search

Home  >  Q&A  >  body text

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

PHP扩展选用的是php-amqp

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

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

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

@modi 的答案补全代码:

天蓬老师天蓬老师2896 days ago866

reply all(3)I'll reply

  • 迷茫

    迷茫2017-04-10 13:14:03

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

    $conn = new AMQPConnection();
    //...
    $queue = new AMQPQueue($conn);
    $queue->setFlags(AMQP_PASSIVE);
    $messageCount = $queue->declare($queueName); // <- 这里
    //...

    reply
    0
  • PHPz

    PHPz2017-04-10 13:14:03

    看了手册http://php.net/manual/en/book.amqp.ph...,好像没有相应的方法

    reply
    0
  • 怪我咯

    怪我咯2017-04-10 13:14:03

    楼主请教一个问题,如何获取未被领取走的消息(包括Un-ack的消息)

    reply
    0
  • Cancelreply