使用PHP访问RabbitMQ消息队列的方法示例
更新时间：2018年06月06日 14:30:07 作者：Zach-vip
这篇文章主要介绍了使用PHP访问RabbitMQ消息队列的方法,结合实例形式分析了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
交换建立
<?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);
}
更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP数据结构与算法教程》、《php程序设计算法总结》、《php字符串(string)用法总结》、《PHP数组(Array)操作技巧大全》、《PHP常用遍历算法与技巧总结》及《PHP数学运算技巧总结》
希望本文所述对大家PHP程序设计有所帮助。
相关文章
本文主要介绍了PHP调用Go服务的正确方式 - Unix Domain Sockets，对进程间通信感兴趣的同学，可以参考一下。2021-05-05
phpmyadmin里面导入sql语句格式的大量数据的方法2010-06-06
我们在实现PHP弹出对话框之后，一般还需要返回原来页面或者用新的页面替换原来的页面等，本文将会讲解详细代码编写，需要的朋友可以参考下2015-09-09
抖音直播是当今热门的实时互动平台之一,用户在直播间内发送的弹幕消息是互动的关键组成部分,在本文中,我们将介绍如何使用 PHP 技术实现抖音直播弹幕的抓取,文中通过代码示例给大家介绍的非常详细,需要的朋友可以参考下2023-12-12
本文主要介绍了PHP程序指定的过程原理。为了以后能开发PHP扩展，就一定要了解PHP的执行顺序。这篇文章就是为C开发PHP扩展做铺垫。2021-05-05
微信公众平台开发教程④ ThinkPHP框架下微信支付功能图文详解
这篇文章主要介绍了微信公众平台开发ThinkPHP框架下微信支付功能,结合图文形式详细分析了基于thinkPHP框架的微信支付功能实现步骤、操作技巧与相关注意事项,需要的朋友可以参考下2019-04-04
一个英文语句怎样把它的每个单词的字母顺序颠倒而单词顺序不变？2010-08-08
以下是对数组非数字键名引号的必要性进行了详细的分析介绍，需要的朋友可以过来参考下2013-08-08
这篇文章主要介绍了php数组使用规则,实例分析了php中数组的用法,具有一定参考借鉴价值,需要的朋友可以参考下2015-02-02
详解WordPress中分类函数wp_list_categories的使用
这篇文章主要介绍了详解WordPress中分类函数wp_list_categories的使用,文中罗列其主要参数的功能和写法,需要的朋友可以参考下2016-01-01
最新评论