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

发布时间：2022-06-16 10:59 所属栏目：121 来源：互联网

导读：本文实例讲述了php实现通过stomp协议连接ActiveMQ操作，分享给大家供大家参考，具体如下：前面介绍了php ActiveMQ的安装与使用，这里再来讲述一下php通过stomp协议连接ActiveMQ。一、安装php的stomp扩展 http://pecl.php.net/package/stomp 如：stomp-2.0.

　　本文实例讲述了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测试。

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

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

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

　　然后我们通过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。

（编辑：ASP站长网）