How to use ActiveMQ instance sharing with PHP-PHP Tutorial-php.cn

How to use ActiveMQ instance sharing with PHP

小云云

Release： 2023-03-19 21:34:02

Original

2643 people have browsed it

Features of the point-to-point model: Only one consumer can receive the message and cannot consume it repeatedly. This article mainly shares with you how to use ActiveMQ in PHP. I hope it can help you.

Producer producer.php code:

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

Copy after login

Consumer 1consumer1.php code:

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

Copy after login

Consumer 2consumer2.php code:

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

Copy after login

Execution result The picture is as follows:

How to use ActiveMQ instance sharing with PHP

Use the Publish/Subscribe (Publish Subscribe) model

Publish/Subscribe model features:

Multiple Consumers can all receive messages

Can be consumed repeatedly

Producer producer.php code:

{    // 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());
}

Copy after login

Consumer 1consumer1. PHP code:

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

Copy after login

Consumer2consumer2.php code:

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

Copy after login

The execution result is as follows:

How to use ActiveMQ instance sharing with PHP

##Related recommendations:

Related understanding of Session settings in ActiveMQ

php-activemq ajax call configuration issue

The above is the detailed content of How to use ActiveMQ instance sharing with PHP. For more information, please follow other related articles on the PHP Chinese website!