使用PHP访问RabbitMQ消息队列的方法示例

rpm -ivh http://mirror.neu.edu.cn/fedora/epel/6/x86_64/epel-release-6-8.noarch.rpmyum install php-pecl-amqp

<?php$connection = new AMQPConnection();$connection->connect();$channel = new AMQPChannel($connection);$exchange = new AMQPExchange($channel);$exchange->setName('exchange1');$exchange->setType('fanout');$exchange->declare();

<?php$connection = new AMQPConnection();$connection->connect();$channel = new AMQPChannel($connection);$queue = new AMQPQueue($channel);$queue->setName('queue1');$queue->declare();

<?php$connection = new AMQPConnection();$connection->connect();$channel = new AMQPChannel($connection);$queue = new AMQPQueue($channel);$queue->setName('queue1');$queue->declare();$queue->bind('exchange1', 'routekey');

<?php$connection = new AMQPConnection();$connection->connect();$channel = new AMQPChannel($connection);$exchange = new AMQPExchange($channel);$exchange->setName('exchange5');$exchange->setType('fanout');$exchange->declare();for($i = 0; $i < 2000000; $i++) { $exchange->publish("message $i", "routekey");}

<?php$connection = new AMQPConnection();$connection->connect();$channel = new AMQPChannel($connection);$queue = new AMQPQueue($channel);$queue->setName('queue1');$queue->declare();$queue->bind('exchange1', 'routekey');while (true) {  $queue->consume(function($envelope, $queue){   echo $envelope->getBody(), PHP_EOL;  }, AMQP_AUTOACK);}