本文例項講述了php 使用ActiveMQ傳送訊息，與處理訊息操作。分享給大家供大家參考，具體如下：

我們以一個簡單的使用者註冊為例，當用戶點選註冊按鈕後，我們傳送一個訊息，後臺php接收到該訊息然後處理。

1.php程式碼如下：

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

$obj = new Stdclass();
//下面這些資料，實際中是使用者通過前端頁面post來的，這裡只做演示
$obj->username = 'test';
$obj->password = '123456';
//傳送一個註冊訊息到佇列，我們這裡模擬使用者註冊
$stomp->send('/queue/userReg',json_encode($obj));

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);
  var_dump($data);

  //我們通過獲取的資料
  //處理相應的邏輯，比如存入資料庫，傳送驗證碼等一系列操作。
  //$db->query("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程式碼如下：

<?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);

  //註冊資訊入庫
  //$ret = db->query("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程式碼如下：

<?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()傳送驗證碼，實際中應該是請求某介面
  $ret = true;
  if($ret) {
   echo $data['username'],'傳送驗證碼成功',PHP_EOL;

   $stomp->ack($frame);
  }
 }
 sleep(1);
}

再次分別執行上面的三個指令碼

> /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程式設計有所幫助。