PHP如何使用ActiveMQ-php教程-PHP中文网

首页

后端开发

php教程

PHP如何使用ActiveMQ

小云云

Feb 07, 2018 am 09:06 AM

activemqphp使用

本文主要和大家分享关于PHP使用ActiveMQ的实例，我们分享了实例代码，并做了相关要点的解释，需要的朋友参考下吧。希望能帮助到大家。

使用点对点(Point To Point)模型

点对点模型特点：

只有一个消费者可以接收到消息
不能重复消费

生产者producer.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 = &#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());
}

消费者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);
  }
}

消费者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);
  }
}

执行结果图如下：

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

发布/订阅模型特点：

多个消费者都可以收到消息
能重复消费
生产者producer.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 = &#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());
}

消费者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);
  }
}

消费者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);
  }
}

执行结果图如下：

相关推荐：

PHP如何使用ActiveMQ实例分享

Java ActiveMQ的代码实例分享

ActiveMQ中Session设置的相关理解

以上是PHP如何使用ActiveMQ的详细内容。更多信息请关注PHP中文网其他相关文章！

声明

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

php怎么把负数转为正整数Apr 19, 2022 pm 08:59 PM

php把负数转为正整数的方法：1、使用abs()函数将负数转为正数，使用intval()函数对正数取整，转为正整数，语法“intval(abs($number))”；2、利用“~”位运算符将负数取反加一，语法“~$number + 1”。

php怎么实现几秒后执行一个函数Apr 24, 2022 pm 01:12 PM

实现方法：1、使用“sleep(延迟秒数)”语句，可延迟执行函数若干秒；2、使用“time_nanosleep(延迟秒数,延迟纳秒数)”语句，可延迟执行函数若干秒和纳秒；3、使用“time_sleep_until(time()+7)”语句。

Java ActiveMQ 的 20 个最佳实践Feb 20, 2024 pm 09:48 PM

1.选择合适的客户端传输协议ActiveMQ支持多种客户端传输协议，包括STOMP、AMQP和OpenWire。根据您的应用程序需求选择合适的协议，以优化性能和可靠性。2.配置消息持久性持久性消息即使在服务器重新启动后也能持久化，而非持久性消息则不会。对于关键消息，选择持久性以确保可靠传递。演示代码：//设置消息持久性MessageProducerproducer=session.createProducer(destination);producer.setDeliveryMode(Deliv