PHP使用ActiveMQ实例
更新时间：2018年02月05日 14:25:45 投稿：laozhang
本篇文章是一篇关于PHP使用ActiveMQ的实例，我们分享了实例代码，并做了相关要点的解释，需要的朋友参考下吧。
使用点对点(Point To Point)模型
点对点模型特点：
- 只有一个消费者可以接收到消息
- 不能重复消费
生产者producer.php代码：
<?php
try {
// 1.建立连接
$stomp = new Stomp('tcp://47.52.119.21:61613');
// 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());
}
消费者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);
}
}
消费者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);
}
}
执行结果图如下：
使用发布/订阅(Publish Subscribe)模型
发布/订阅模型特点：
多个消费者都可以收到消息
能重复消费
生产者producer.php代码：
<?php
try {
// 1.建立连接
$stomp = new Stomp('tcp://47.52.119.21:61613');
// 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());
}
消费者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);
}
}
消费者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);
}
}
执行结果图如下：
相关文章
这篇文章主要介绍了Joomla开启SEF的方法,以Joomla1.5分析了开启SEF的步骤与相关注意事项,需要的朋友可以参考下2016-05-05
本文给大家介绍thinkphp实现更新数据的实例详解以及thinkphp更新数据库的五种方法，本文介绍的非常不错，具有参考借鉴价值，感兴趣的朋友可以参考下2016-06-06
这篇文章主要介绍了使用PHP实现阻止用户上传成人照片或者裸照,方法和思路都非常的不错，推荐给大家，需要的朋友可以参考下2014-12-12
这篇文章主要介绍了CodeIgniter配置之SESSION用法,结合实例形式分析了PHP中session的运行原理并演示了CI框架下session的配置与使用方法,需要的朋友可以参考下2016-01-01
这篇文章主要介绍了PHP程序中使用adodb连接不同数据库的代码实例,具体的用法示例中用switch语句写了一个汇总式的支持,需要的朋友可以参考下2015-12-12
使用PHPStudy搭建Cloudreve网盘服务的流程步骤
自云存储概念兴起已经有段时间了,各互联网大厂也纷纷加入战局,一时间公有云盘遍地开花,今天我们就为大家介绍,如何使用Cpolar与Cloudreve,在个人Windows电脑上搭建一个强大的PHP云盘系统,需要的朋友可以参考下2024-02-02
这篇文章主要介绍了 Laravel5.7 数据库操作迁移的实现方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-04-04
解决在laravel中leftjoin带条件查询没有返回右表为NULL的问题
今天小编就为大家分享一篇解决在laravel中leftjoin带条件查询没有返回右表为NULL的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-10-10
这篇文章主要介绍了Yii2单元测试用法,结合实例形式分析了Yii2单元测试的具体实现与使用技巧,需要的朋友可以参考下2016-11-11
PHP 面向对象程序设计（oop）学习笔记 (四) - 异常处理类Exception
异常经常被用来处理一些在程序正常执行中遇到的各种类型的错误。比如做数据库链接时，你就要处理数据库连接失败的情况。使用异常可以提高我们程序的容错特性，从而使我们的应用程序更加的稳定和健壮。2014-06-06
最新评论