脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 网络编程 → PHP编程 → php实例 → PHP使用ActiveMQ

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

执行结果图如下：

您可能感兴趣的文章:

相关文章

  • php微信公众账号开发之五个坑（二）

    php微信公众账号开发之五个坑（二）

    这篇文章主要为大家详细介绍了php微信公众账号开发之五个坑,具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2016-09-09
  • PHP+MySQL投票系统的设计和实现分享

    PHP+MySQL投票系统的设计和实现分享

    php投票系统的设计和实现，需要的朋友可以参考下代码与数据库结果设计，最后脚本之家提供了源码下载
    2012-09-09
  • PHP函数分享之curl方式取得数据、模拟登陆、POST数据

    PHP函数分享之curl方式取得数据、模拟登陆、POST数据

    这篇文章主要介绍了curl方式取得数据、模拟登陆、POST数据,需要的朋友可以参考下
    2014-06-06
  • Laravel 5框架学习之表单验证

    Laravel 5框架学习之表单验证

    Laravel 通过 Validation 类让您可以简单、方便的验证数据正确性及查看相应的验证错误信息。如果是更复杂的验证场景，你可能需要创建一个"表单请求"。表单请求是一个自定义的请求类包含了一些验证的逻辑。你可以通过 Artisan 的命令行 make:request 来创建一个表单请求类
    2015-04-04
  • laravel框架创建授权策略实例分析

    laravel框架创建授权策略实例分析

    这篇文章主要介绍了laravel框架创建授权策略,结合实例形式分析了laravel框架创建授权策略的相关步骤、实现方法与操作注意事项,需要的朋友可以参考下
    2019-11-11
  • php 二维数组快速排序算法的实现代码

    php 二维数组快速排序算法的实现代码

    这篇文章主要介绍了php 二维数组快速排序算法的实现代码的相关资料,希望通过本文能帮助到大家，让大家实现这样的功能，需要的朋友可以参考下
    2017-10-10
  • ajax完美实现两个网页 分页功能的实例代码

    ajax完美实现两个网页 分页功能的实例代码

    ajax完美实现两个网页 分页功能的实例代码，需要的朋友可以参考一下
    2013-04-04
  • 50个优秀经典PHP算法大集合 附源码

    50个优秀经典PHP算法大集合 附源码

    这篇文章主要介绍了50个优秀经典PHP算法大集合 附源码,非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下
    2020-08-08
  • Google PR查询接口checksum新算法

    Google PR查询接口checksum新算法

    前些日子一篇N久之前的老文忽然成了被阅读的热点，检查之后才发现自己使用那段代码来做pr查询的页面已经不能正常得到URL的Page Rank值了
    2009-01-01
  • Win7 64位系统下PHP连接Oracle数据库

    Win7 64位系统下PHP连接Oracle数据库

    项目中遇到一个问题，即怎么在Windows下连接Oracle进行开发。几乎所有的例子都是基于Mysql的，Oracle的连接本身在Windows平台下就显得比较复杂。这里便长话短说，只记录有用部分，希望对大家有所帮助
    2014-08-08

最新评论