php 利用activeMq+stomp实现消息队列
一、ActiveMQ的安装与配置
1. 安装JDK
2. 安装ActiveMQ
下载地址：http://activemq.apache.org/download.html# wget http://www.apache.org/dyn/closer.cgi?filename=/activemq/5.15.3/apache-activemq-5.15.3-bin.tar.gz&action=download
3. 配置ActiveMQ，使其支持stomp
在配置文件/usr/local/activemq/conf/activemq.xml，添加
<transportConnectors> <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireformat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://localhost:61613"/></transportConnectors>
4. 启动ActiveMQ
#/usr/local/activemq/bin/activemq start
二、安装php的stomp扩展
1.下载stomp扩展包
#cd /home#wget http://pecl.php.net/get/stomp-2.0.1.tgz
2.编译安装
phpize报 Cannot find autoconf 请安装 autoconf后再执行 yum install m4 和 yum install autoconf
#tar zxf stomp-2.0.1.tgz#cd stomp-2.0.1#/usr/local/php/bin/phpize#./configure --with-php-config=/usr/local/php/bin/php-config其中 php-config 和 phpize 所在的目录是相同的， 如果php-config路径不是上面,比如上面我用 /usr/bin/phpize，则在这一步我用：# ./configure --with-php-config=/usr/bin/php-config#make#make install
3.修改php.ini
请通过phpinfo()查看ini文件位置
#vim /usr/local/php/lib/php.ini增加行： extension="/usr/local/php/lib/php/extensions/no-debug-non-zts-20151012/stomp.so" 重启PHP#systemctl restart php-fpm
三、php---实现定时从消息队列里取出数据
### 1.php
<?php
$stomp = new Stomp('tcp://192.168.1.222:61613');
$obj = new Stdclass();//下面这些数据，实际中是用户通过前端页面post来的，这里只做演示
$obj->username = 'test';
$obj->password = '123456';//发送一个注册消息到队列，我们这里模拟用户注册
$stomp->send('/queue/userReg', json_encode($obj));?>
### 2.php
<?php
$stomp = new Stomp('tcp://192.168.1.222:61613');//订阅只对一个有效，如果启动多个脚本，只有一个会接收到消息
$stomp->subscribe('/queue/userReg');
while(true) { //判断是否有读取的信息
if($stomp->hasFrame()) {
$frame = $stomp->readFrame();
$data = json_decode($frame->body, true);
var_dump($data);
//我们通过获取的数据
//处理相应的逻辑，比如存入数据库，发送验证码等一系列操作。
//$db->query("insert into user values('{$username}','{$password}')");
//sendVerify();
//表示消息被处理掉了，ack()函数很重要
$stomp->ack($frame);
}
sleep(1);
}?>四、参考资料
ActiveMQ+In+Action.pdf
网站不承担任何有关评论的责任
- 最新评论
- 总共条评论
