主页 > 知识库 > php实现通过stomp协议连接ActiveMQ操作示例

php实现通过stomp协议连接ActiveMQ操作示例

热门标签:阿里云 银行业务 Linux服务器 服务器配置 电子围栏 Mysql连接数设置 科大讯飞语音识别系统 团购网站

本文实例讲述了php实现通过stomp协议连接ActiveMQ操作。分享给大家供大家参考,具体如下:

前面介绍了php ActiveMQ的安装与使用,这里再来讲述一下php通过stomp协议连接ActiveMQ。

一、安装php的stomp扩展

http://pecl.php.net/package/stomp

如:stomp-2.0.0.tgz

> tar xf stomp-1.0.9.tgz
> cd stomp-1.0.9
> /data/php56/bin/phpize
> ./configure --with-php-config=/data/php56/bin/php-config
> make  make install

修改php.ini文件

> vi /data/php56/lib/php.ini

注意这里php环境的扩展路径(请自行修改)

extension_dir = "/data/php56/lib/php/extensions/no-debug-zts-20131226/"
extension=stomp.so

查看扩展是否安装成功

> /data/php56/bin/php -m|grep Stomp

二、使用stomp扩展连接ActiveMQ

我们通过http://192.168.1.222:8161/admin/后台创建一个队列test测试。

并在该test队列中发送一条消息

然后我们通过php获取该队列中的消息,代码如下:

?php
try {
 //61613默认的端口,在ActiveMQ目录conf/activemq.xml文件可查看
 $stomp = new Stomp('tcp://192.168.1.222:61613');
} catch (StompException $e) {
 die('error: ' . $e->getMessage());
}

//订阅一个消息队列
$stomp->subscribe('/queue/test');
//读取队列
$frame = $stomp->readFrame();
//输出消息体内容
echo $frame->body, PHP_EOL;

运行上面的代码

> /data/php56/bin/php 1.php

更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP扩展开发教程》、《PHP网络编程技巧总结》、《php curl用法总结》、《PHP数组(Array)操作技巧大全》、《PHP数据结构与算法教程》、《php程序设计算法总结》及《php字符串(string)用法总结》

希望本文所述对大家PHP程序设计有所帮助。

您可能感兴趣的文章:
  • php ActiveMQ的安装与使用方法图文教程
  • PHP使用ActiveMQ实现消息队列的方法详解
  • PHP使用ActiveMQ实例
  • PHP Beanstalkd消息队列的安装与使用方法实例详解
  • PHP高级编程之消息队列原理与实现方法详解
  • php+redis实现消息队列功能示例
  • PHP+RabbitMQ实现消息队列的完整代码
  • 使用PHP访问RabbitMQ消息队列的方法示例
  • php实现websocket实时消息推送
  • php 使用ActiveMQ发送消息,与处理消息操作示例

标签:江苏 广元 衢州 蚌埠 大理 衡水 萍乡 枣庄

巨人网络通讯声明:本文标题《php实现通过stomp协议连接ActiveMQ操作示例》,本文关键词  ;如发现本文内容存在版权问题,烦请提供相关信息告之我们,我们将及时沟通与处理。本站内容系统采集于网络,涉及言论、版权与本站无关。
  • 相关文章
  • 收缩
    • 微信客服
    • 微信二维码
    • 电话咨询

    • 400-1100-266