最新消息:XAMPP默认安装之后是很不安全的,我们只需要点击左方菜单的 "安全"选项,按照向导操作即可完成安全设置。

php使用activemq

XAMPP案例 中文小张 578浏览 0评论

一、下载:

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

您必须 登录 才能发表评论!