Rumah > pembangunan bahagian belakang > tutorial php > PHP如何使用ActiveMQ实例分享

PHP如何使用ActiveMQ实例分享

小云云
Lepaskan: 2023-03-19 21:34:02
asal
2630 orang telah melayarinya

点对点模型特点:只有一个消费者可以接收到消息,不能重复消费。本文主要和大家分享PHP如何使用ActiveMQ实例分享,希望能帮助到大家。

生产者producer.php代码:

<?
phptry {  
  // 1.建立连接    $stomp = new Stomp(&#39;tcp://47.52.119.21:61613&#39;);    
// 2.实例化类    $obj = new Stdclass();    
// 3.获取数据    for($i=0; $i<3; $i++)
{        $obj->username = &#39;test&#39;;        
$obj->password = &#39;123456&#39;;        
$queneName     = "/queue/userReg";        
// 4.发送一个注册消息到队列       
 $stomp->send($queneName, json_encode($obj));   
 }} catch (StompException $e) 
{    die(&#39;Connection failed: &#39; 
. $e->getMessage());
}
Salin selepas log masuk

消费者1consumer1.php代码:

<?
php$stomp = new Stomp(&#39;tcp://localhost:61613&#39;);
$stomp->subscribe(&#39;/queue/userReg&#39;);while (true) 
{    //判断是否有读取的信息    if ($stomp->hasFrame()) 
{        $frame = $stomp->readFrame();        
$data  = json_decode($frame->body, true);       
var_dump($data);       
 $stomp->ack($frame);   
 }}
Salin selepas log masuk

消费者2consumer2.php代码:

<?php
$stomp = new Stomp(&#39;tcp://localhost:61613&#39;);$stomp->subscribe(&#39;/queue/userReg&#39;);while (true) 
{    //判断是否有读取的信息    if ($stomp->hasFrame())
{        $frame = $stomp->readFrame();       
$data  = json_decode($frame->body, true);      
  var_dump($data);        $stomp->ack($frame);  
  }}
Salin selepas log masuk

执行结果图如下:

1.jpg

使用发布/订阅(Publish Subscribe)模型

发布/订阅模型特点:

多个消费者都可以收到消息

能重复消费

生产者producer.php代码:

{    // 1.建立连接    
$stomp = new Stomp(&#39;tcp://47.52.119.21:61613&#39;);  
 // 2.实例化类    $obj = new Stdclass();   
 // 3.获取数据    for($i = 0; $i < 3; $i++)
{        $obj->username = &#39;test&#39;;      
  $obj->password = &#39;123456&#39;;        
$queneName     = "/topic/userReg";      
  // 4.发送一个注册消息到队列     
   $stomp->send($queneName, json_encode($obj));   
 }} 
catch (StompException $e)
 {    die(&#39;Connection failed: &#39; . $e->getMessage());
}
Salin selepas log masuk

消费者1consumer1.php代码:

<?php$stomp = new Stomp(&#39;tcp://localhost:61613&#39;);$stomp->subscribe(&#39;/topic/userReg&#39;);
while (true) {    //判断是否有读取的信息    if ($stomp->hasFrame())
 {        $frame = $stomp->readFrame();       
 $data  = json_decode($frame->body, true);    
    var_dump($data);        $stomp->ack($frame);  
  }}
Salin selepas log masuk

消费者2consumer2.php代码:

<?php$stomp = new Stomp(&#39;tcp://localhost:61613&#39;);$stomp->subscribe(&#39;/topic/userReg&#39;);
while (true) {    //判断是否有读取的信息    if ($stomp->hasFrame()) 
{        $frame = $stomp->readFrame();    
    $data  = json_decode($frame->body, true);       
 var_dump($data);      
  $stomp->ack($frame);   
 }}
Salin selepas log masuk

执行结果图如下: 

2.jpg

相关推荐:

ActiveMQ中Session设置的相关理解

php-activemq之ajax调用配置问题

Atas ialah kandungan terperinci PHP如何使用ActiveMQ实例分享. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Label berkaitan:
sumber:php.cn
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan