0

我有一个 python 应用程序，它使用 pika 库将消息推送到 rabbitMQ 队列中。

message='hola'
credentials = pika.PlainCredentials('guest', 'guest')
connection = pika.BlockingConnection(pika.ConnectionParameters(credentials=credentials, host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='myqueue')
channel.basic_publish(exchange='',routing_key='myqueue',body=message)
connection.close()

这样可行。

我需要在 php 应用程序中使用这些消息。我尝试了此页面的 AQMP 示例中提到的这个 - http://www.php.net/manual/en/class.amqpqueue.php（检查函数接收器）

$cnn = new AMQPConnection((array("host"=>"ec2-xxx-xx-xx-xxx.ap-southeast-1.compute.amazonaws.com","login"=>"guest", "password"=>"guest")));
if ($cnn->connect()) {
    echo "Established a connection to the broker";
}
else {
    echo "Cannot connect to the broker";
}

    $queue = new AMQPQueue($cnn); 
    $queue->declare('myqueue'); 
    $queue->bind('', 'myqueue'); 

$msg=$queue->get(AMQP_AUTOACK);
echo $msg->getBody();

抛出这个异常 -

Fatal error: Uncaught exception 'Exception' with message 'Error parsing parameters.' in /home/webroot/amqptest.php:12 Stack trace: #0 /home/webroot/amqptest.php(12): AMQPQueue->declare('myqueue') #1 {main} thrown in /home/webroot/amqptest.php on line 12
4

2 回答 2

1

这应该可行 - 但请记住，没有错误处理或任何循环来重复接收消息。不过，它确实为我成功地从代理中出列/接收了单个消息（如果再次运行空队列，则会崩溃）。

<?php

$cnn = new AMQPConnection();
$cnn->setLogin("guest");
$cnn->setPassword("guest");
$cnn->setHost("localhost");

if ($cnn->connect()) {
    echo "Established a connection to the broker\n";
}
else {
    echo "Cannot connect to the broker\n";
}

$channel = new AMQPChannel($cnn);
$queue = new AMQPQueue($channel);
$queue->setName('myqueue');

// the default / nameless) exchange does not require a binding
// as the broker declares a binding for each queue with key
// identical to the queue name. error 403 if you try yourself.
//$queue->bind('', 'myqueue');

$msg=$queue->get(AMQP_AUTOACK);

echo $msg->getBody();
echo "\n";

?>

具体来说，请注意 AMQPConnection 现在需要通过属性而不是数组进行配置；您必须使用 AMQPChannel 传递给 AMQPQueue 对象；并且绑定到默认交换中的队列将不起作用/是不必要的。要查看效果，请尝试取消注释显示 $queue->bind 的行 :-)

我将这两个脚本的副本作为公共 Gist 放在 Github 上 - https://gist.github.com/2988379

于 2012-06-25T11:59:04.460 回答
0

我认为文件是错误的。您需要 AMQPChannel 来创建队列，而不是 AMQPConnection。可以找到队列的构造函数的定义：

AMQPQueue::__construct(AMQPChannel channel)

在 AMQP 包的源代码中：amqp_queue.c

于 2012-06-28T10:14:25.757 回答