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

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

瑾兮 发布于 2017-10-28 字数 242 浏览 1367 回复 1

PHP扩展选用的是php-amqp

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

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

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

如果你对这篇文章有疑问,欢迎到本站 社区 发帖提问或使用手Q扫描下方二维码加群参与讨论,获取更多帮助。

扫码加入群聊

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

甜柠檬 2017-10-28 1 楼
//连接RabbitMQ
$conn_args = array( 'host'=>'localhost' , 'port'=> '5672', 'login'=>'guest' , 'password'=> 'guest','vhost' =>'/');
$conn = new AMQPConnection($conn_args);
$conn->connect();
$channel = new AMQPChannel($conn);

//创建queue名称,使用exchange,绑定routingkey
$q = new AMQPQueue($channel);
$q->setName('actionlog');
$q->setFlags(AMQP_PASSIVE);

$messageCount = 0;
$messageCount = $q->declare();
$conn->disconnect();

echo $messageCount;