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

本文实例讲述了使用PHP访问RabbitMQ消息队列的方法,分享给大家供大家参考,具体如下.

扩展安装

PHP访问RabbitMQ实际使用的是AMQP协议，所以我们只要安装epel库中的php-pecl-amqp这个包即可

rpm -ivh http://mirror.neu.edu.cn/fedora/epel/6/x86_64/epel-release-6-8.noarch.rpm

yum install php-pecl-amqp

交换建立

1. $connection = new AMQPConnection(); 
2. $connection->connect(); 
3. $channel = new AMQPChannel($connection); 
4. $exchange = new AMQPExchange($channel); 
5. $exchange->setName('exchange1'); 
6. $exchange->setType('fanout'); 
7. $exchange->declare(); 

队列建立

1. $connection = new AMQPConnection(); 
2. $connection->connect(); 
3. $channel = new AMQPChannel($connection); 
4. $queue = new AMQPQueue($channel); 
5. $queue->setName('queue1'); 
6. $queue->declare(); 

队列绑定

1. $connection = new AMQPConnection(); 
2. $connection->connect(); 
3. $channel = new AMQPChannel($connection); 
4. $queue = new AMQPQueue($channel); 
5. $queue->setName('queue1'); 
6. $queue->declare(); 
7. $queue->bind('exchange1', 'routekey'); 

消息发送

1. $connection = new AMQPConnection(); 
2. $connection->connect(); 
3. $channel = new AMQPChannel($connection); 
4. $exchange = new AMQPExchange($channel); 
5. $exchange->setName('exchange5'); 
6. $exchange->setType('fanout'); 
7. $exchange->declare(); 
8. for($i = 0; $i < 2000000; $i++) { 
9.  $exchange->publish("message $i", "routekey"); 
10. } 

消息接收

1. $connection = new AMQPConnection(); 
2. $connection->connect(); 
3. $channel = new AMQPChannel($connection); 
4. $queue = new AMQPQueue($channel); 
5. $queue->setName('queue1'); 
6. $queue->declare(); 
7. $queue->bind('exchange1', 'routekey'); 
8. while (true) { 
9.   $queue->consume(function($envelope, $queue){ 
10.    echo $envelope->getBody(), PHP_EOL; 
11.   }, AMQP_AUTOACK); 
12. }