PHP使用ActiveMQ實(shí)例

更新時(shí)間：2018年02月05日 14:25:45 投稿：laozhang

本篇文章是一篇關(guān)于PHP使用ActiveMQ的實(shí)例，我們分享了實(shí)例代碼，并做了相關(guān)要點(diǎn)的解釋，需要的朋友參考下吧。

使用點(diǎn)對(duì)點(diǎn)(Point To Point)模型

點(diǎn)對(duì)點(diǎn)模型特點(diǎn)：

只有一個(gè)消費(fèi)者可以接收到消息
不能重復(fù)消費(fèi)

生產(chǎn)者producer.php代碼：

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

消費(fèi)者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);
  }
}

消費(fèi)者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);
  }
}

執(zhí)行結(jié)果圖如下：

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

發(fā)布/訂閱模型特點(diǎn)：

多個(gè)消費(fèi)者都可以收到消息
能重復(fù)消費(fèi)
生產(chǎn)者producer.php代碼：

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

消費(fèi)者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);
  }
}

消費(fèi)者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);
  }
}

執(zhí)行結(jié)果圖如下：

您可能感興趣的文章:

PHP
ActiveMQ

相關(guān)文章

php微信公眾賬號(hào)開(kāi)發(fā)之五個(gè)坑（二）
這篇文章主要為大家詳細(xì)介紹了php微信公眾賬號(hào)開(kāi)發(fā)之五個(gè)坑,具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2016-09-09
PHP+MySQL投票系統(tǒng)的設(shè)計(jì)和實(shí)現(xiàn)分享
php投票系統(tǒng)的設(shè)計(jì)和實(shí)現(xiàn)，需要的朋友可以參考下代碼與數(shù)據(jù)庫(kù)結(jié)果設(shè)計(jì)，最后腳本之家提供了源碼下載
2012-09-09
PHP函數(shù)分享之curl方式取得數(shù)據(jù)、模擬登陸、POST數(shù)據(jù)
這篇文章主要介紹了curl方式取得數(shù)據(jù)、模擬登陸、POST數(shù)據(jù),需要的朋友可以參考下
2014-06-06
Laravel 5框架學(xué)習(xí)之表單驗(yàn)證
Laravel 通過(guò) Validation 類讓您可以簡(jiǎn)單、方便的驗(yàn)證數(shù)據(jù)正確性及查看相應(yīng)的驗(yàn)證錯(cuò)誤信息。如果是更復(fù)雜的驗(yàn)證場(chǎng)景，你可能需要?jiǎng)?chuàng)建一個(gè)"表單請(qǐng)求"。表單請(qǐng)求是一個(gè)自定義的請(qǐng)求類包含了一些驗(yàn)證的邏輯。你可以通過(guò) Artisan 的命令行 make:request 來(lái)創(chuàng)建一個(gè)表單請(qǐng)求類
2015-04-04
laravel框架創(chuàng)建授權(quán)策略實(shí)例分析
這篇文章主要介紹了laravel框架創(chuàng)建授權(quán)策略,結(jié)合實(shí)例形式分析了laravel框架創(chuàng)建授權(quán)策略的相關(guān)步驟、實(shí)現(xiàn)方法與操作注意事項(xiàng),需要的朋友可以參考下
2019-11-11
php 二維數(shù)組快速排序算法的實(shí)現(xiàn)代碼
這篇文章主要介紹了php 二維數(shù)組快速排序算法的實(shí)現(xiàn)代碼的相關(guān)資料,希望通過(guò)本文能幫助到大家，讓大家實(shí)現(xiàn)這樣的功能，需要的朋友可以參考下
2017-10-10
ajax完美實(shí)現(xiàn)兩個(gè)網(wǎng)頁(yè) 分頁(yè)功能的實(shí)例代碼
ajax完美實(shí)現(xiàn)兩個(gè)網(wǎng)頁(yè) 分頁(yè)功能的實(shí)例代碼，需要的朋友可以參考一下
2013-04-04
50個(gè)優(yōu)秀經(jīng)典PHP算法大集合附源碼
這篇文章主要介紹了50個(gè)優(yōu)秀經(jīng)典PHP算法大集合附源碼,非常不錯(cuò)，具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
2020-08-08
Google PR查詢接口checksum新算法
前些日子一篇N久之前的老文忽然成了被閱讀的熱點(diǎn)，檢查之后才發(fā)現(xiàn)自己使用那段代碼來(lái)做pr查詢的頁(yè)面已經(jīng)不能正常得到URL的Page Rank值了
2009-01-01
Win7 64位系統(tǒng)下PHP連接Oracle數(shù)據(jù)庫(kù)
項(xiàng)目中遇到一個(gè)問(wèn)題，即怎么在Windows下連接Oracle進(jìn)行開(kāi)發(fā)。幾乎所有的例子都是基于Mysql的，Oracle的連接本身在Windows平臺(tái)下就顯得比較復(fù)雜。這里便長(zhǎng)話短說(shuō)，只記錄有用部分，希望對(duì)大家有所幫助
2014-08-08