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

2025-04-04 15:45:05
推荐回答(3个)
回答1:

lare一个队列,置AMQP_PASSIVE标志位,就不会影响服务端状态,并返回消息计数。
$conn = new AMQPConnection();
//...
$queue = new AMQPQueue($conn);
$queue->setFlags(AMQP_PASSIVE);
$messageCount = $queue->declare($queueName); // <- 这里
//...

回答2:

eclare一个队列,置AMQP_PASSIVE标志位,就不会影响服务端状态,并返回消息计数。
全选复制放进笔记$conn = new AMQPConnection();
//...
$queue = new AMQPQueue($conn);
$queue->setFlags(AMQP_PASSIVE);
$messageCount = $queue->declare($queueName); // <- 这里
//...

回答3:

参考代码如下来实现:
echo ' web-root = '.$_SERVER['DOCUMENT_ROOT'].'
';
echo ' current-file = '.__FILE__.'
';
echo ' current-dir = '.dirname(__FILE__).'
';
echo ' http-root = '.$_SERVER['HTTP_HOST'].'
';
echo ' web-position = '.$_SERVER['PHP_SELF'].'
';
$file='c:/webroot/index.php';
echo ' file-position = '.$file.'
';
$fileWebAddress='http://'.str_replace($_SERVER['DOCUMENT_ROOT'],$_SERVER['HTTP_HOST'],$file);
echo ' file-web-position = '.$fileWebAddress.'
';
?>