php使用activemq php使用activemq

一、下载：

http://activemq.apache.org/activemq-5140-release.html

二、安装

tar -zxvf apache-activemq-5.15.3-bin.tar.gz cd apache-activemq-5.14.0 cd bin ./activemq start

三、防火墙端口

8161(web管理页面端口） 61616（activemq服务监控端口）

四、web管理页面

默认用户名密码 admin/admin

文章图片
image.png 五使用
使用stomp-php

connect(); //发送消息到队列 $con->send("/queue/test", "test"); $con->send("/queue/test", "test", array('persistent' => 'true')); //支持持久化echo "Sent message with body 'test'\n"; // 订阅队列 $con->subscribe("/queue/test"); // 从队列中接收消息 $msg = $con->readFrame(); // 执行自定义任务 if ($msg != null) { echo "Received message with body '$msg->body'\n"; // 将消息标记为在队列中收到 $con->ack($msg); } else { echo "Failed to receive a message\n"; }// 关闭连接 $con->disconnect(); ?>

【php使用activemq】使用扩展Stomp

100, 'email'=>'xxx@baidu.com', 'address'=>'beijing', ),JSON_UNESCAPED_UNICODE); /* 连接 */ try { $stomp = new Stomp('tcp://localhost:61613'); } catch(StompException $e) { die('Connection failed: ' . $e->getMessage()); }/* 向队列“Foo”发送消息*/ $stomp->send($queue, $msg,array('persistent'=> true)); /* 订阅来自“Foo”队列的消息 */ $stomp->subscribe($queue); /* 读取数据 */ $frame = $stomp->readFrame(); if ($frame->body === $msg) { var_dump($frame->body); /* 确认接收到*/ $stomp->ack($frame); }/* 连接关闭 */ unset($stomp);