Rabbitmq 是一个功【gōng】能【néng】很强大【dà】消息队【duì】列系统,使用【yòng】起来可能不像某些 push 、pop 类型【xíng】的队列简单(比如 redis 的list),Rabbitmq 支【zhī】持消息的订阅发【fā】布模式【shì】,方便大型【xíng】系统各个服务组【zǔ】件之间解耦和通信。我们【men】首先要了解一些【xiē】基本【běn】概念【niàn】。
1 2 3 4 5 |
Connection:即连接, 与你日【rì】常理解【jiě】的连接没有什么不同【tóng】,比如 redis的连接,mysql的连接
Channel:即通【tōng】道, 可以理解为一个连【lián】接中的子通道,想【xiǎng】象一【yī】条高速【sù】公路,可能是 4车道的,也【yě】可能是 8 车道的,这些车道就是【shì】 Channel。
Exchange : 交换机【jī】,如【rú】果【guǒ】你知道交【jiāo】换机设备的【de】话,它的原理跟交换【huàn】机【jī】是基本一样的。
routingkey : 用来绑【bǎng】定交换【huàn】机和【hé】队列的【de】一个字符串。发送【sòng】消息时需【xū】要指定 routingKey, 绑定了此 routingKey的队列将接收到【dào】此消息。
queue队列: 消息经过交换机,最终发送到队列中。
|
发布消息:
新建文件send.php
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 |
<?php
$conn = [
// Rabbitmq 服务地址
'host' => '127.0.0.1' ,
// Rabbitmq 服务端口
'port' => '5672' ,
// Rabbitmq 帐号
'login' => 'guest' ,
// Rabbitmq 密码
'password' => 'guest' ,
];
// 创建连接和channel
$conn = new AMQPConnection($conn);
if (!$conn->connect()) {
die( "Cannot connect to the broker!n" );
}
$channel = new AMQPChannel($conn);
// 用来绑定交换机和队列
$routingKey = 'key_1' ;
$ex = new AMQPExchange($channel);
// 交换机名称
$exchangeName = 'ex1' ;
$ex->setName($exchangeName);
// 设置交换机类型
$ex->setType(AMQP_EX_TYPE_DIRECT);
// 设置交换机是否持久化消息
$ex->setFlags(AMQP_DURABLE);
for ($i=0; $i<5; ++$i){
echo "Send Message:" .$ex->publish( date ( 'H:i:s' ). "用户" .$i. "注册" , $routingKey ). "n" ;
}
|
消费消息:
新建文件receive.php
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 |
<?php
$conn = [
// Rabbitmq 服务地址
'host' => '127.0.0.1' ,
// Rabbitmq 服务端口
'port' => '5672' ,
// Rabbitmq 帐号
'login' => 'guest' ,
// Rabbitmq 密码
'password' => 'guest' ,
];
// 创建连接和channel
$conn = new AMQPConnection($conn);
if (!$conn->connect()) {
die( "Cannot connect to the broker!n" );
}
$channel = new AMQPChannel($conn);
$exchangeName = 'ex1' ;
// 创建交换机
$ex = new AMQPExchange($channel);
$ex->setName($exchangeName);
$ex->setType(AMQP_EX_TYPE_DIRECT); //direct 类型
$ex->setFlags(AMQP_DURABLE); // 持久化
// 创建队列
$queueName = 'queue1' ;
$q = new AMQPQueue($channel);
$q->setName($queueName);
$q->setFlags(AMQP_DURABLE);
$q->declareQueue();
// 用于绑定队列和交换机,跟 send.php 中的一致。
$routingKey = 'key_1' ;
$q->bind($exchangeName, $routingKey);
// 接收消息
$q->consume( function ($envelope, $queue) {
$msg = $envelope->getBody();
echo $msg. "n" ; // 处理消息
}, AMQP_AUTOACK);
$conn->disconnect();
|
运行代码:
启动rabbitmq服务。
一开始队列是不存在【zài】的,我们需要【yào】先启动 consume.php 来初【chū】始化【huà】队列【liè】,打开命令行页面,运行【háng】
1 |
php receive.php
|
启动后 , php receive.php 将阻塞【sāi】监听队【duì】列消息【xī】。
然后打开新的命令行窗口运行:
1 |
php send.php
|
然后在新 receive.php 所在【zài】的终【zhōng】端【duān】窗口将看【kàn】到接收到的消息。
阿里企业邮箱、网易企业邮箱、新网企业邮箱
【标准版】400元/年/5用户/无限容量
【外贸版】500元/年/5用户/无限容量
其它服务:网站【zhàn】建【jiàn】设、企业邮箱、数字证【zhèng】书ssl、400电话、
联系方式:电话:13714666846 微信同号
【标准版】400元/年/5用户/无限容量
【外贸版】500元/年/5用户/无限容量
其它服务:网站【zhàn】建【jiàn】设、企业邮箱、数字证【zhèng】书ssl、400电话、
联系方式:电话:13714666846 微信同号
声【shēng】明:本站所有作【zuò】品(图文、音视频)均由用户自【zì】行上【shàng】传分享,或互联【lián】网相关【guān】知【zhī】识整合,仅供网友学【xué】习交流,若您的权利被侵害,请联系 管理【lǐ】员【yuán】 删除。
本文链接【jiē】:https://www.city96.com/article_32734.html