使用 RabbitMQ 进行异步队列处理

Question

我在 RabbitMQ 中寻找异步队列处理的好例子时遇到了问题。
我试图开始在服务器端实现这样的东西：

//here I declare the connection exchange and queue
$this->connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
$this->channel = $this->connection->channel();            
$this->channel->exchange_declare("exchange", 'direct', false, false, false);
list($this->queue_name, ,) = $this->channel->queue_declare("Queue", false, false, true, false);

while($envelope = $queue->get()) 
{
    // do work here...
}

问题是我返回的是队列名称而不是队列引用，因此我将能够在以下while 循环中使用它。

我也尝试创建和声明一个队列，如this link 中所写，但我的RabbitMQ 交付包中没有AMQPQueue 之类的类。

有人知道如何获取队列实例以便能够使用get 方法吗？

Answer 1

你似乎在使用这个库：https://github.com/videlalvaro/php-amqplib

看看这个例子：https://github.com/videlalvaro/php-amqplib/blob/master/demo/amqp_consumer.php

还有：http://www.rabbitmq.com/tutorials/tutorial-one-php.html