Как получить количество сообщений в RabbitMQ?

Question

[romaaa32]

Как получить текущее количество неподтвержденных сообщений в RabbitMQ?
С использованием PhpAmqpLib это возможно осуществить?

Answer 1

[Евгений Самсонов]

Для конкретной очереди
https://github.com/php-amqplib/RabbitMqBundle/issu...

Comments

[romaaa32]

Показывает 0 сообщений, а их за 100, не могу разобраться почему

[Евгений Самсонов]

romaaa32, А как делаете?

[romaaa32]

Евгений Самсонов,

list($queue, $messageCount, $consumerCount) = $channel->queue_declare('тут_имя_очереди', true);
        echo $queue."<br>", $messageCount."<br>", $consumerCount."<br>";

$queue возващает имя очереди
$messageCount: 0
$consumerCount: 1

[romaaa32]

Евгений Самсонов, я затупил, все правильно. Количество сообщений реально 0, но количество неподтвержденных больше 100. Их как узнать?

[romaaa32]

Евгений Самсонов, Хотя с той информации, что дает такой способ могу сделать то что мне нужно, но все равно интересно как узнать информацию о неподтвержденных сообщениях)

[Евгений Самсонов]

romaaa32, что значит неподтвержденных?

[romaaa32]

$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);

Это через HTTP API: /api/queues

[romaaa32]

Евгений Самсонов,

rabbitMQ->channel->basic_consume(
    'name',
    '',
    false,
    true,
    false,
    false,
    $callback
);

4 параметр true говорит отправлять подтверждение обработчику когда задача будет выполнена.

Вот так у меня сделано, и пока работник колдует над сообщением - оно висит в очереди, как неподтвержденное (колдовать может и по пол часа).

[Евгений Самсонов]

romaaa32,
> Количество сообщений реально 0
А это о чем? Запутался.
Посмотрю, как будет время

[romaaa32]

Евгений Самсонов,
Скриншот из пользовательского интерфейса rabbitmq management.
1) Сообщения в очереди
2) Сообщения ждущие подтверждения
3) Общее количество сообщений, в очереди и ждущих подтверждения

$messageCount: показывает количество с 1-го пункта

Мне нужно знать количество во 2 пункте

[Евгений Самсонов]

romaaa32, не нашел, как это сделать из PhpAmqpLib. Но отправив GET запрос на <http_rabbit_host>/api/queues/%2f/<queue_name> можно получить всю информацию по указанной очереди. В ответе будет JSON, где одно из значений messages_ready

%2f это дефолтный vhost "/"

[romaaa32]

Евгений Самсонов, спасибо!