本文實(shí)例講述了php 使用ActiveMQ發(fā)送消息，與處理消息操作。分享給大家供大家參考，具體如下：
我們以一個(gè)簡(jiǎn)單的用戶注冊(cè)為例，當(dāng)用戶點(diǎn)擊注冊(cè)按鈕后，我們發(fā)送一個(gè)消息，后臺(tái)php接收到該消息然后處理。
1.php代碼如下：
?php
$stomp = new Stomp('tcp://192.168.1.222:61613');
$obj = new Stdclass();
//下面這些數(shù)據(jù)，實(shí)際中是用戶通過(guò)前端頁(yè)面post來(lái)的，這里只做演示
$obj->username = 'test';
$obj->password = '123456';
//發(fā)送一個(gè)注冊(cè)消息到隊(duì)列，我們這里模擬用戶注冊(cè)
$stomp->send('/queue/userReg', json_encode($obj));
2.php代碼如下：
?php
$stomp = new Stomp('tcp://192.168.1.222:61613');
//訂閱只對(duì)一個(gè)有效，如果啟動(dòng)多個(gè)腳本，只有一個(gè)會(huì)接收到消息
$stomp->subscribe('/queue/userReg');
while(true) {
//判斷是否有讀取的信息
if($stomp->hasFrame()) {
$frame = $stomp->readFrame();
$data = json_decode($frame->body, true);
var_dump($data);
//我們通過(guò)獲取的數(shù)據(jù)
//處理相應(yīng)的邏輯，比如存入數(shù)據(jù)庫(kù)，發(fā)送驗(yàn)證碼等一系列操作。
//$db->query("insert into user values('{$username}','{$password}')");
//sendVerify();
//表示消息被處理掉了，ack()函數(shù)很重要
$stomp->ack($frame);
}
sleep(1);
}
分別運(yùn)行上面兩個(gè)腳本文件
> /data/php56/bin/php 1.php
> /data/php56/bin/php 2.php
我們還可以把上面的2.php代碼分成多步執(zhí)行。
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);
//注冊(cè)信息入庫(kù)
//$ret = db->query("insert into user values('{$data['username']}', '{$data['password']}')");
//這里演示直接設(shè)成true了
$ret = true;
if($ret) {
echo $data['username'], '入庫(kù)成功', PHP_EOL;
//如果入庫(kù)成功，再次把數(shù)據(jù)發(fā)送到另一個(gè)消息隊(duì)列中，進(jìn)行下一步處理
$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()發(fā)送驗(yàn)證碼，實(shí)際中應(yīng)該是請(qǐng)求某接口
$ret = true;
if($ret) {
echo $data['username'], '發(fā)送驗(yàn)證碼成功', PHP_EOL;
$stomp->ack($frame);
}
}
sleep(1);
}
再次分別運(yùn)行上面的三個(gè)腳本
> /data/php56/bin/php 1.php
> /data/php56/bin/php 2.php
> /data/php56/bin/php 3.php
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《PHP擴(kuò)展開發(fā)教程》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《php curl用法總結(jié)》、《PHP數(shù)組(Array)操作技巧大全》、《PHP數(shù)據(jù)結(jié)構(gòu)與算法教程》、《php程序設(shè)計(jì)算法總結(jié)》及《php字符串(string)用法總結(jié)》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
您可能感興趣的文章:- php實(shí)現(xiàn)通過(guò)stomp協(xié)議連接ActiveMQ操作示例
- php ActiveMQ的安裝與使用方法圖文教程
- PHP使用ActiveMQ實(shí)現(xiàn)消息隊(duì)列的方法詳解
- PHP使用ActiveMQ實(shí)例
- PHP Beanstalkd消息隊(duì)列的安裝與使用方法實(shí)例詳解
- PHP高級(jí)編程之消息隊(duì)列原理與實(shí)現(xiàn)方法詳解
- php+redis實(shí)現(xiàn)消息隊(duì)列功能示例
- PHP+RabbitMQ實(shí)現(xiàn)消息隊(duì)列的完整代碼
- 使用PHP訪問(wèn)RabbitMQ消息隊(duì)列的方法示例
- php實(shí)現(xiàn)websocket實(shí)時(shí)消息推送
