服务器之家

服务器之家 > 正文

php 使用ActiveMQ发送消息,与处理消息操作示例

时间:2021-09-29 14:49     来源/作者:怀素真

本文实例讲述了php 使用ActiveMQ发送消息,与处理消息操作。分享给大家供大家参考,具体如下:

我们以一个简单的用户注册为例,当用户点击注册按钮后,我们发送一个消息,后台php接收到该消息然后处理。

1.php代码如下:

  1. <?php
  2. $stomp = new Stomp('tcp://192.168.1.222:61613');
  3.  
  4. $obj = new Stdclass();
  5. //下面这些数据,实际中是用户通过前端页面post来的,这里只做演示
  6. $obj->username = 'test';
  7. $obj->password = '123456';
  8. //发送一个注册消息到队列,我们这里模拟用户注册
  9. $stomp->send('/queue/userReg', json_encode($obj));

2.php代码如下:

  1. <?php
  2. $stomp = new Stomp('tcp://192.168.1.222:61613');
  3. //订阅只对一个有效,如果启动多个脚本,只有一个会接收到消息
  4. $stomp->subscribe('/queue/userReg');
  5.  
  6. while(true) {
  7. //判断是否有读取的信息
  8. if($stomp->hasFrame()) {
  9. $frame = $stomp->readFrame();
  10.  
  11. $data = json_decode($frame->body, true);
  12. var_dump($data);
  13.  
  14. //我们通过获取的数据
  15. //处理相应的逻辑,比如存入数据库,发送验证码等一系列操作。
  16. //$db->query("insert into user values('{$username}','{$password}')");
  17. //sendVerify();
  18.  
  19. //表示消息被处理掉了,ack()函数很重要
  20. $stomp->ack($frame);
  21. }
  22. sleep(1);
  23. }

分别运行上面两个脚本文件

  1. > /data/php56/bin/php 1.php
  2. > /data/php56/bin/php 2.php

php 使用ActiveMQ发送消息,与处理消息操作示例

我们还可以把上面的2.php代码分成多步执行。

2.php代码如下:

  1. <?php
  2. $stomp = new Stomp('tcp://192.168.1.222:61613');
  3. $stomp->subscribe('/queue/userReg');
  4.  
  5. while(true) {
  6. //判断是否有读取的信息
  7. if($stomp->hasFrame()) {
  8. $frame = $stomp->readFrame();
  9.  
  10. $data = json_decode($frame->body, true);
  11.  
  12. //注册信息入库
  13. //$ret = db->query("insert into user values('{$data['username']}', '{$data['password']}')");
  14. //这里演示直接设成true了
  15. $ret = true;
  16. if($ret) {
  17. echo $data['username'], '入库成功', PHP_EOL;
  18. //如果入库成功,再次把数据发送到另一个消息队列中,进行下一步处理
  19. $stomp->send('/queue/sendVerify', $frame->body);
  20.  
  21. $stomp->ack($frame);
  22. }
  23. }
  24. sleep(1);
  25. }

3.php代码如下:

  1. <?php
  2. $stomp = new Stomp('tcp://192.168.1.222:61613');
  3. $stomp->subscribe('/queue/sendVerify');
  4.  
  5. while(true) {
  6. //判断是否有读取的信息
  7. if($stomp->hasFrame()) {
  8. $frame = $stomp->readFrame();
  9.  
  10. $data = json_decode($frame->body, true);
  11.  
  12. //$ret = sendVerify()发送验证码,实际中应该是请求某接口
  13. $ret = true;
  14. if($ret) {
  15. echo $data['username'], '发送验证码成功', PHP_EOL;
  16.  
  17. $stomp->ack($frame);
  18. }
  19. }
  20. sleep(1);
  21. }

再次分别运行上面的三个脚本

  1. > /data/php56/bin/php 1.php
  2. > /data/php56/bin/php 2.php
  3. > /data/php56/bin/php 3.php

php 使用ActiveMQ发送消息,与处理消息操作示例

php 使用ActiveMQ发送消息,与处理消息操作示例

希望本文所述对大家PHP程序设计有所帮助。

原文链接:https://www.cnblogs.com/jkko123/p/6685902.html

标签:

相关文章

热门资讯

yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
2021年耽改剧名单 2021要播出的59部耽改剧列表
2021年耽改剧名单 2021要播出的59部耽改剧列表 2021-03-05
返回顶部