PHP utilise l'analyse de cas ActiveMQ (avec code)

Cette fois je vais vous apporter une analyse de cas de PHP utilisant ActiveMQ (avec code). Quelles sont les précautions pour PHP utilisant ActiveMQ Voici un cas pratique, jetons un oeil.

Utiliser le modèle point à point

Caractéristiques du modèle point à point :

• Un seul consommateur peut recevoir le message

• ne peut pas être consommé à plusieurs reprises

producteur producteur.code php:

<?php
try {
  // 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 = 'test';
    $obj->password = '123456';
    $queneName   = "/queue/userReg";
    // 4.发送一个注册消息到队列
    $stomp->send($queneName, json_encode($obj));
  }
} catch (StompException $e) {
  die('Connection failed: ' . $e->getMessage());
}

Consommation Consommateur1consommateur1. Code php :

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

Code Consumer2consumer2.php :

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

Le résultat de l'exécution est le suivant :

Utiliser Publier Modèle d'abonnement

Fonctionnalités du modèle de publication/abonnement :

Plusieurs consommateurs peuvent recevoir des messages
Peut être consommé à plusieurs reprises
Code PHP du producteur :

<?php
try {
  // 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 = 'test';
    $obj->password = '123456';
    $queneName   = "/topic/userReg";
    // 4.发送一个注册消息到队列
    $stomp->send($queneName, json_encode($obj));
  }
} catch (StompException $e) {
  die('Connection failed: ' . $e->getMessage());
}

Code Consumer1consumer1.php :

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

Code Consumer2consumer2.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);
  }
}

Le résultat de l'exécution est le suivant :

Je pense que vous maîtrisez la méthode après avoir lu le cas dans cet article. Pour des informations plus intéressantes, veuillez prêter attention aux autres articles connexes sur le site Web chinois de php !

Lecture recommandée :

Explication détaillée des étapes pour transmettre les paramètres lors de l'ouverture d'une application exe locale avec php et js

Comment réaliser la fixation de la suppression de php Dossiers et fichiers sous le chemin

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!