如何在php-amqplib (RabbitMQ)中获取队列中的所有消息？

Question

目前，我正在使用https://github.com/php-amqplib/php-amqplib，并且我已经在这个存储库中阅读了很多示例，但是我仍然不明白如何从队列中获取所有消息？

我只需要接收一些消息，按值对它们进行分组，然后执行一个操作。

有没有可能使用RabbitMQ？

我如何在php中实现这一点？

Answer 1

<?php

use PhpAmqpLib\Connection\AMQPStreamConnection;

$connection = new AMQPStreamConnection('rabbitmq', 5672, 'guest', 'guest');
$channel = $connection->channel();
$queueName = 'task_queue';
$channel->queue_declare($queueName, false, true, false, false);
$result = $channel->basic_get($queueName);

var_dump($result);

$channel->close();
$connection->close();

Answer 2

您无法通过调用单个方法获取所有当前可用的消息。

最接近的解决方案是使用basic_consume方法。

例如：

function process_message($message)
{
    echo "Received message '" . $message->body . "'\n";

    /** Do your grouping here **/

}

$channel->basic_consume($queue, '', false, false, false, false, 'process_message');

// Loop as long as the channel has callbacks registered
while (count($channel->callbacks)) {
    $channel->wait();
}

您可以查看official RabbitMQ PHP tutorial或demo from php-amqplib。