PHP消息队列rabbitmq——linux环境
1.依赖包安装
wget http://erlang.org/download/otp_src_18.1.tar.gz
tar -zxvf otp_src_18.1.tar.gz
cd otp_src_18.1
./configure --prefix=/usr/local/erlang
make
make install
# 配置erlang环境变量
vim /etc/profile
# 增加内容：
export PATH="$PATH:/usr/local/erlang/bin"
# 保存退出，并刷新变量
source /etc/profile
# 测试erlang是否安装成功
# 安装完成以后，执行erl看是否能打开eshell，用’halt().’退出，注意后面的点号，那是erlang的结束符。
[root@localhost src]# erl
Erlang/OTP 18 [erts-7.1] [source] [64-bit] [async-threads:10] [hipe] [kernel-poll:false]
Eshell V7.1 (abort with ^G)
3.安装rabbitmq依赖文件,安装rabbitmq
安装rabbitmq-c依赖包
| 1 |
yum install libtool autoconf
|
安装rabbitmq-c
wget -c https://github.com/alanxz/rabbitmq-c/releases/download/v0.8.0/rabbitmq-c-0.8.0.tar.gz tar zxf rabbitmq-c-0.8.0.tar.gz cd rabbitmq-c-0.8.0 ./configure --prefix=/usr/local/rabbitmq-c-0.8.0 make && make install
安装php拓展 amqp
wget -c http://pecl.php.net/get/amqp-1.9.3.tgz tar zxf amqp-1.9.3.tgz cd amqp-1.9.3 /usr/local/php/bin/phpize ./configure --with-php-config=/usr/local/php/bin/php-config --with-amqp --with-librabbitmq-dir=/usr/local/rabbitmq-c-0.8.0 make && make install
这里注意一下：我的是PHP7，所以安装rabbitmq-c和amqp安装的都是最新版本。网上很多教程都是基于PHP5的安装，rabbitmq-c版本一般都是0.5.0，amqp是1.6.这里注意根据你的PHP版本做好区分。不然在安装amqp，make编译的时候会错。
编辑php.ini文件，增加amqp扩展支持
| 1 |
vim /usr/local/php/etc/php.ini
|
添加一行：
?| 1 |
extension=amqp.so
|
重启php-fpm
| 1 |
/etc/init.d/php-fpm restart
|
查看是否安装成功，输出phpinfo()或者输入 php -m 都可以查看；
至此，所有的环境搭建完毕！
二.运行demo
我们把消费者的代码稍微优化一下，在接受消息的时候，只有在有消息的时候处理：
如图
我们开启两个消费者进程监听队列，然后生产者开始投放；
执行结果如图
可以看到，生产者投放了五个消息，被两个消费者依次有序的进行取出队列处理。