php中使用RabbitMq消息队列

1.RabbitMQ 是一个在AMQP基础上完成的,可复用的企业消息系统。消息队列中间件,支持多种语言,以及跨语言消息传递,安装配置文档请参照官网说明;

2. php中如何使用RabbitMQ呢?

2.1 安装php-amqp扩展,下载地址: http://pecl.php.net/package/amqp下载解压后文件如下图:将php_amqp.dll文件添加到php  ext扩展目录中并追加到php.ini文件中

2.2 使用的服务器为apache  需要将httpd.conf中添加一行 LoadFile  “rabbitmq.1.dll安装路径”;

2.3 重启apache,并查看phpinfo信息。只要看到amqp 字样即表示安装成功;

2.4 使用php-amqplib库来实现RabbitMQ消息队列的使用,使用composer 安装:composer.json 文件中require节点找那个添加 “php-amqplib/php-amqplib”:”>=2.6.1″

并执行composer update操作,或使用composer命令   composer require php-amqplib/php-amqplib来安装这个库。

2.5 可以参考github中的代码来实现具体需求 demo地址:https://github.com/php-amqplib/php-amqplib/tree/master/demo,下图两个demo为最基本的消息获取、应答和发送功能

发表评论