<"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代码如下：


<"htmlcode">

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





更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP扩展开发教程》、《PHP网络编程技巧总结》、《php curl用法总结》、《PHP数组(Array)操作技巧大全》、《PHP数据结构与算法教程》、《php程序设计算法总结》及《php字符串(string)用法总结》
希望本文所述对大家PHP程序设计有所帮助。