怎么在php中使用ActiveMQ发送消息

本篇文章给大家分享的是有关怎么在php中使用ActiveMQ发送消息，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。

1.php代码如下：

<?php
$stomp=newStomp('tcp://192.168.1.222:61613');

$obj=newStdclass();
//下面这些数据，实际中是用户通过前端页面post来的，这里只做演示
$obj->username='test';
$obj->password='123456';
//发送一个注册消息到队列，我们这里模拟用户注册
$stomp->send('/queue/userReg',json_encode($obj));

2.php代码如下：

<?php
$stomp=newStomp('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("insertintouservalues('{$username}','{$password}')");
//sendVerify();

//表示消息被处理掉了，ack()函数很重要
$stomp->ack($frame);
}
sleep(1);
}

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

>/data/php56/bin/php1.php
>/data/php56/bin/php2.php

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

2.php代码如下：

<?php
$stomp=newStomp('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("insertintouservalues('{$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=newStomp('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/php1.php
>/data/php56/bin/php2.php
>/data/php56/bin/php3.php

以上就是怎么在php中使用ActiveMQ发送消息，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注恰卡编程网行业资讯频道。