使用PHP访问RabbitMQ消息队列的方法示例
发布时间：2020-12-12 22:31:13 所属栏目：PHP教程 来源：网络整理
导读：本篇章节讲解使用PHP访问RabbitMQ消息队列的方法。供大家参考研究具体如下： 扩展安装 PHP访问RabbitMQ实际使用的是AMQP协议，所以我们只要安装epel库中的php-pecl-amqp这个包即可 交换建立 connect();$channel = new AMQPChannel($connection);$e
|
本篇章节讲解使用PHP访问RabbitMQ消息队列的方法。分享给大家供大家参考，具体如下： 扩展安装PHP访问RabbitMQ实际使用的是AMQP协议，所以我们只要安装epel库中的php-pecl-amqp这个包即可 交换建立connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange1');
$exchange->setType('fanout');
$exchange->declare();
队列建立connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->declare();
队列绑定connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->declare();
$queue->bind('exchange1','routekey');
消息发送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");
}
消息接收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);
}
更多关于PHP相关内容感兴趣的读者可查看本站专题：《》、《》、《》、《》、《》及《》 希望本文所述对大家PHP程序设计有所帮助。 （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |