怎么在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

交换建立

connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName(&＃39;exchange1&＃39;);
$exchange->setType(&＃39;fanout&＃39;);
$exchange->declare();

队列建立

connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&＃39;queue1&＃39;);
$queue->declare();

队列绑定

connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&＃39;queue1&＃39;);
$queue->declare();
$queue->bind(&＃39;exchange1&＃39;, &＃39;routekey&＃39;);

消息发送

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

消息接收

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

以上就是怎么在PHP项目中访问RabbitMQ消息队列，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注编程笔记行业资讯频道。