php监控rabbitmq队列的数据量

<?php
#代理连接
$conn = new AMQPConnection( $configs );#$config是连接rabbitmq的配置
$conn->connect();
$chanel = new AMQPChannel( $conn );
$queue = new AMQPQueue( $chanel );
$queue->setFlags( AMQP_PASSIVE );
$queueName = 'purchase.sync.#.wms.queue';#需要监控的队列名
$queue->setName( $queueName );
$messageCount = $queue->declare();#队列No acked数据量

补上$configs的参数

$configs = [
    'host'            => RABBITMQ_HOST ,
    'port'            => RABBITMQ_PORT ,
    'vhost'           => RABBITMQ_VHOST ,
    'login'           => RABBITMQ_USER ,
    'password'        => RABBITMQ_PASS ,
];

版权声明:本文为yolo_me原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。