使用点对点(Point To Point)模型
点对点模型特点:
- 只有一个消费者可以接收到消息
- 不能重复消费
rush:PHP;">
PHP
try {
// 1.建立连接
$stomp = new Stomp('tcp://47.52.119.21:61613');
// 2.实例化类
$obj = new Stdclass();
// 3.获取数据
for($i=0; $i<3; $i++){
$obj->username = 'test';
$obj->password = '123456';
$queneName = "/queue/userReg";
// 4.发送一个注册消息到队列
$stomp->send($queneName,json_encode($obj));
}
} catch (StompException $e) {
die('Connection Failed: ' . $e->getMessage());
}
rush:PHP;">
$stomp = new Stomp('tcp://localhost:61613');
$stomp->subscribe('/queue/userReg');
$stomp->subscribe('/queue/userReg');
while (true) {
//判断是否有读取的信息
if ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
$data = json_decode($frame->body,true);
var_dump($data);
$stomp->ack($frame);
}
}
rush:PHP;">
$stomp = new Stomp('tcp://localhost:61613');
$stomp->subscribe('/queue/userReg');
$stomp->subscribe('/queue/userReg');
while (true) {
//判断是否有读取的信息
if ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
$data = json_decode($frame->body,true);
var_dump($data);
$stomp->ack($frame);
}
}
执行结果图如下:
使用发布/订阅(Publish Subscribe)模型
发布/订阅模型特点:
多个消费者都可以收到消息 能重复消费 生产者producer.PHP代码:
rush:PHP;">
PHP
try {
// 1.建立连接
$stomp = new Stomp('tcp://47.52.119.21:61613');
// 2.实例化类
$obj = new Stdclass();
// 3.获取数据
for($i = 0; $i < 3; $i++){
$obj->username = 'test';
$obj->password = '123456';
$queneName = "/topic/userReg";
// 4.发送一个注册消息到队列
$stomp->send($queneName,json_encode($obj));
}
} catch (StompException $e) {
die('Connection Failed: ' . $e->getMessage());
}
rush:PHP;">
$stomp = new Stomp('tcp://localhost:61613');
$stomp->subscribe('/topic/userReg');
$stomp->subscribe('/topic/userReg');
while (true) {
//判断是否有读取的信息
if ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
$data = json_decode($frame->body,true);
var_dump($data);
$stomp->ack($frame);
}
}
$stomp = new Stomp('tcp://localhost:61613');
$stomp->subscribe('/topic/userReg');
while (true) {
//判断是否有读取的信息
if ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
$data = json_decode($frame->body,true);
var_dump($data);
$stomp->ack($frame);
}
}
$stomp->subscribe('/topic/userReg');
while (true) {
//判断是否有读取的信息
if ($stomp->hasFrame()) {
$frame = $stomp->readFrame();
$data = json_decode($frame->body,true);
var_dump($data);
$stomp->ack($frame);
}
}
执行结果图如下:
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。