zoukankan      html  css  js  c++  java
  • 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
    

  • 相关阅读:
    linux下18种监测网络带宽方式
    python常用正则表达式
    python获取当前路径
    python获取本机的IP
    Linux 误卸载自带python后的解决办法
    jmeter分布式运行
    jmeter非GUI的运行命令
    linux下安装jmeter
    java基础笔记(8)
    java基础笔记(7)
  • 原文地址:https://www.cnblogs.com/jkko123/p/6685728.html
Copyright © 2011-2022 走看看