之前简单的了解了ActiveMQ的安装和启动,及ActiveMQ连接,这篇文章我们来了解ActiveMQ的使用,下文介绍了PHP怎样用ActiveMQ发送消息,并且进行处理的操作,文中示例介绍的很详细的介绍,有需要的朋友可以参考,接下来就跟随小编来了解看看吧!
我们以一个简单的用户注册为例,当用户点击注册按钮后,我们发送一个消息,后台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); }
分别运行上面两个脚本文件
> /data/php56/bin/php 1.php > /data/php56/bin/php 2.php
我们还可以把上面的2.php代码分成多步执行。
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); //注册信息入库 //$ret = db->query("insert into user values('{$data['username']}', '{$data['password']}')"); //这里演示直接设成true了 $ret = true; if($ret) { echo $data['username'], '入库成功', PHP_EOL; //如果入库成功,再次把数据发送到另一个消息队列中,进行下一步处理 $stomp->send('/queue/sendVerify', $frame->body); $stomp->ack($frame); } } sleep(1); }
3.php代码如下:
<?php $stomp = new Stomp('tcp://192.168.1.222:61613'); $stomp->subscribe('/queue/sendVerify'); while(true) { //判断是否有读取的信息 if($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); //$ret = sendVerify()发送验证码,实际中应该是请求某接口 $ret = true; if($ret) { echo $data['username'], '发送验证码成功', PHP_EOL; $stomp->ack($frame); } } sleep(1); }
再次分别运行上面的三个脚本
> /data/php56/bin/php 1.php > /data/php56/bin/php 2.php > /data/php56/bin/php 3.php
关于PHP怎样用ActiveMQ发送消息,并且进行处理的操作就介绍到这,感兴趣的朋友可以参考示例代码,希望本文能对大家学习ActiveMQ的使用有帮助,想要了解更多大家可以关注其它的相关文章。
文本转载自脚本之家
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。