PHP使用ActiveMQ實例

2024-05-05 00:02:13

字體：大中小

來源：轉載

供稿：網友

使用點對點(Point To Point)模型

點對點模型特點：

只有一個消費者可以接收到消息
不能重復消費

生產者producer.php代碼：

<?phptry {  // 1.建立連接  $stomp = new Stomp('tcp://47.52.119.21:61613');  // 2.實例化類  $obj = new Stdclass();  // 3.獲取數據  for($i=0; $i<3; $i++){    $obj->username = 'test';    $obj->password = '123456';    $queneName   = "/queue/userReg";    // 4.發送一個注冊消息到隊列    $stomp->send($queneName, json_encode($obj));  }} catch (StompException $e) {  die('Connection failed: ' . $e->getMessage());}

消費者1consumer1.php代碼：

<?php$stomp = new Stomp('tcp://localhost:61613');$stomp->subscribe('/queue/userReg');while (true) {  //判斷是否有讀取的信息  if ($stomp->hasFrame()) {    $frame = $stomp->readFrame();    $data = json_decode($frame->body, true);    var_dump($data);    $stomp->ack($frame);  }}

消費者2consumer2.php代碼：

<?php$stomp = new Stomp('tcp://localhost:61613');$stomp->subscribe('/queue/userReg');while (true) {  //判斷是否有讀取的信息  if ($stomp->hasFrame()) {    $frame = $stomp->readFrame();    $data = json_decode($frame->body, true);    var_dump($data);    $stomp->ack($frame);  }}

執行結果圖如下：

PHP,ActiveMQ

使用發布/訂閱(Publish Subscribe)模型

發布/訂閱模型特點：

多個消費者都可以收到消息
能重復消費
生產者producer.php代碼：

<?phptry {  // 1.建立連接  $stomp = new Stomp('tcp://47.52.119.21:61613');  // 2.實例化類  $obj = new Stdclass();  // 3.獲取數據  for($i = 0; $i < 3; $i++){    $obj->username = 'test';    $obj->password = '123456';    $queneName   = "/topic/userReg";    // 4.發送一個注冊消息到隊列    $stomp->send($queneName, json_encode($obj));  }} catch (StompException $e) {  die('Connection failed: ' . $e->getMessage());}

消費者1consumer1.php代碼：

<?php$stomp = new Stomp('tcp://localhost:61613');$stomp->subscribe('/topic/userReg');while (true) {  //判斷是否有讀取的信息  if ($stomp->hasFrame()) {    $frame = $stomp->readFrame();    $data = json_decode($frame->body, true);    var_dump($data);    $stomp->ack($frame);  }}

消費者2consumer2.php代碼：

?php$stomp = new Stomp('tcp://localhost:61613');$stomp->subscribe('/topic/userReg');while (true) {  //判斷是否有讀取的信息  if ($stomp->hasFrame()) {    $frame = $stomp->readFrame();    $data = json_decode($frame->body, true);    var_dump($data);    $stomp->ack($frame);  }}

執行結果圖如下：

PHP,ActiveMQ