一、下载：
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
五 使用
使用stomp-php
<?php
require __DIR__ . ‘/../vendor/autoload.php’;
// 引入库
use FuseSource\Stomp\Stomp;
// 创建连接
$con = new Stomp(“tcp://localhost:61613”);
// 连接
$con->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();
?>
使用扩展Stomp
<?php
$queue = ‘msg_notify’;
$msg = json_encode(array(
‘uid’=>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);
转载请注明：XAMPP中文组官网 » php使用activemq