(编辑:jimmy 日期: 2024/10/4 浏览:2)
本文实例讲述了php 使用ActiveMQ发送消息,与处理消息操作。分享给大家供大家参考,具体如下:
我们以一个简单的用户注册为例,当用户点击注册按钮后,我们发送一个消息,后台php接收到该消息然后处理。
1.php代码如下:
<"htmlcode"><"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代码如下:
<"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代码如下: