PDF《第一个例子：Hello World 1》

1.

1 1.2 1.3 1.4 1.5 目录 介绍 第一个例子:Hello World 工作队列:Work QUeues 发布/订阅:Publish/Subscribe 路由:Routing

1 RabbitMQ 教程 本教程涵盖了利用RabbitMQ创建消息传递应用程序的基础知识.你需要安装RabbitMQ服务 器来完成本教程,请阅读安装向导.本教程的实例代码是开源的,和RabbitMQ网站一样. 目录 1.Hello World! 做最简单的事情 Python Java Ruby PHP C# Javascript Go Elixir Objective-C Swift 2.Work queues 任务分发(竞争消费者模式) Python Java Ruby PHP C# Javascript 介绍

2 Go Elixir Objective-C Swift 3.Publish/Subscribe 向多个消费者发送消息 Python Java Ruby PHP C# Javascript Go Elixir Objective-C Swift 4.Routing 选择性的接收消息 Python Java Ruby PHP C# 介绍

3 Javascript Go Elixir Objective-C Swift 5.Topics 基于模式(主题)来接收消息 Python Java Ruby PHP C# Javascript Go Elixir Objective-C Swift 6.RPC 请求/回复(RPC) 模式实例 介绍

4 Python Java Ruby PHP C# Javascript Go Elixir Objective-C Swift 获取帮助 如果你对RabbitMQ有任何问题/意见,你可以随时在邮件列表中询问. AMQP 0-9-1概述和快速参考 一旦你已经完成了教程(或如果你想跳过),你可能希望阅读RabbitMQ概念的介绍,并浏览 我们的AMQP 0-9-1快速参考指南. 介绍

5 Hello World 先决条件 本教程假定RabbitMQ在localhost默认端口(5672)上安装和运行.如果您使用其他主机,端 口或凭据,连接设置将需要调整. 在哪里获得帮助 如果您在阅读本教程时遇到问题,可以通过邮件列表与我们联系. 简介 RabbitMQ是一个消息代理.主要想法很简单:它接受和转发消息.你可以把它当成一个邮 局:当你发送邮件到邮政信箱,你很确定邮递员最终将邮件发送给你的收件人.使用这个隐 喻RabbitMQ是一个邮政信箱,邮局和邮递员. RabbitMQ和邮局之间的主要区别是它不处理纸张,而是接受,存储和转发二进制数据块的消 息. 在使用RabbitMQ前,先让我们了解一些基本术语: Producing:发送消息,发送消息的程序是生产者(producer),我们用P来表示它: Queue: queue 是邮箱的名称,它们存在于RabbitMQ中,虽然消息流经RabbitMQ和您的 应用程序,但它们只能存储在队列中.队列不受任何限制,它可以存储尽可能多的消 息,你喜欢 - 它本质上是一个无限缓冲区.许多生产者可以发送去往一个队列的消息,许 多消费者可以尝试从一个队列接收数据. Consuming: 消费与接收具有相似的含义.消费者(consumer)是大多数等待接收消息的程 序. 第一个例子:Hello World

6 生产者(producer),消费者(consumer)和代理(broker)不必驻留在同一台机器上;

事实上 在大多数应用中他们没有. Hello World! 使用php-amqplib 在这一部分,我们将在php中编写两个应用程序:发送单个消息的生产者、以及接收消息并将 其打印出来的消费者,我们将讨论php-amqplib API中的一些细节,集中讨论这个非常简单的 事情.这是一个 Hello World 的消息. 在下图中, P 是我们的生产者, C 是我们的消费者.中间的框是一个队列--RabbitMQ代表消 费者保存的消息缓冲区. php-amqplib 客户端库 RabbitMQ支持多种协议,本教程包含AMQP 0-9-1,它是一个用于消息传递的开放式协议. RabbitMQ有许多不同语言的客户端.我们将在本教程中使用php-amqplib,并使用Composer 进行依赖关系管理. 在你的项目根目录中添加 composer.json文件,并加入下列内容: { require : { php-amqplib/php-amqplib : 2.5.* } } 接下来在终端中执行下列命令来安装php-amqplib: $ composer install 如果你没有安装composer,请自行安装. 现在我们已经安装了php-amqplib库,我们可以编写一些代码. Sending 第一个例子:Hello World

7 我们将发送消息的程序命名为 send.php,和接收消息的程序命名为 receive.php,发送方链接 到RabbitMQ,发送单条消息,然后退出. 在send.php中,我们需要包含库并使用必要的类 require_once __DIR__ . '

/vendor/autoload.php'

;

use PhpAmqpLibConnectionAMQPStreamConnection;

use PhpAmqpLibMessageAMQPMessage;

接下来,我们创建一个到服务器的链接: $connection = new AMQPStreamConnection('

localhost'

,5672,'

guest'

,'

guest'

);

$channel = $connection->

channel();

$connection 连接socket链接,并为我们处理协议版本和认证等等.在这个案例中,我们连接 到本地的broker,所以这里是localhost.如果我们想连接到其它机器上的broker,只需要提供 它的名字或者IP地址. 然后我们创建一个通道(channel),这里有大多数的API来完成我们的任务. 要发送消息,我们必须先声明一个队列(queue),然后才可以向队列发送消息: $channel->

queue_declare('

hello'

,false,false,false,false);

$msg = new AMQPMessage('

Hello World!'

);

$channel->

basic_publish($msg,'

'

,'

hello'

);

echo [x] Sent '

Hello World!'

n ;

声明队列是幂等的,它只有在它不存在时才会被创建. 消息内容是一个字节数组,所以你可以把任何想发送的内容编码后发送过来. 最后我们要关闭$channel 和$connection来释放资源: $channel->

close();

$connection->

close();

上面就是整个 send.php的代码了. 第一个例子:Hello World

8 发送程序无法运行? 如果你第一次使用RabbitMQ,并且没有看到程序最后输出的Sent来告知你成功了,你可 能会挠着头来思考到底是哪出错了? 可能是broker没有足够的可用空间(默认情况下,它 至少需要1GB的空间来运行),因此拒绝接受消息.你可以检查下broker的日志文件来确 定问题的原因,并在必要时减少该限制,配置文档里面有教你如何配置disk_free_limit. Receiving 以上就是我们的sender了,我们的接收器是推送来自RabbitMQ的消息,因此与发送单个消息 的sender是不一样的.我们继续运行监听消息并将其打印出来. receive.php 中同样需要include类库和use必要的类: require_once __DIR__ . '

/vendor/autoload.php'

;

use PhpAmqpLibConnectionAMQPStreamConnection;

设置与sender 相同,我们打开一个连接(connection)和一个通道(channel),并且声明一个我 们将要使用的队列,这里要注意到队列必须和sender发送的队列是同一个. $connection = new AMQPStreamConnection('

localhost'

,5672,'

guest'

,'

guest'

);

$channel = $connection->

channel();

$channel->

queue_declare('

hello'

,false,false,false,false);

echo '

[*] Waiting for messages. To exit press CTRL+C'

, n ;

注意:我们在这里声明队列,是因为我们可能在发送方之前启动接收方,所以我们希望 在尝试使用消息前确保队列存在.并且因为这里声明是幂等的,所以在发送方声明时, 则可能不会创建新的队列,而是打开现有的队列 我们告诉服务器使用队列来传递消息.我们定义一个php回调(PHP callable),它来接收服务 器发送的消息. 第一个例子:Hello World

9 $callback = function($msg) { echo [x] Received ,$msg->

body, n ;

} $channel->

basic_consume('

hello'

,'

'

,false,true,false,false,$callback);

while(count($channel->

callbacks)) { $channel->

wait();

} 上述代码会阻塞住程序结束,而 $channel有一个回调函数,每当我们收到一个程序时,我们 的$callback函数将被传递接收道德消息. 以上就是receive.php的全部代码了 将它们放在一起 现在我们可以运行这两个脚本了,在终端里,运行发送程序: $ php send.php 然后运行接收程序 $ php receive.php 接收方将通过RabbitMQ接收到的消息打印出来,接收者将继续运行,等待消息(使用Ctrl-C 停止它),所以尝试从另一个终端运行发送者. 如果你想检查队列,你可以运行在RabbitMQ目录下的sbin目录中的rabbitmqctl: $ rabbitmqctl list_queues. 你可以将rabbitmqctl加入到你的环境变量中,那样你就可以直接运行rabbitmqctl,而不用进入 RabbitMQ目录中. 输出:Hello World! 第一个例子:Hello World

10 先决条件 本教程假定RabbitMQ在localhost默认端口(5672)上安装和运行.如果您使用其他主机,端 口或凭据,连接设置将需要调整. 在哪里获得帮助 如果您在阅读本教程时遇到问题,可以通过邮件列表与我们联系. Work Queues 使用php-amqplib 在

第一篇教程中,我们编写程序以从命名队列中发送和接收消息.在这一节中,我们将创建 一个工作队列(work queues),用于在多个工作者之间分配耗时的任务. 工作队列(也叫任务队列)背后主要的想法是避免立刻执行资源密集型任务,并不得不等待它完 成.想法,我们安排任务以后再执行.我们将任务封装为消息,并将其发送到队列.在后台 运行的worker进程将弹出任务并最终执行作业.当你运行了多个workershi时,任务将在它们 之间共享. 此概念在Web应用程序中尤其有用,因为在短期HTTP请求窗口中无法处理复杂任务. 准备 在上一节教程中,我们发送了一个内容为 Hello World! 的消息,现在我们要发送代表复杂任 务的字符串.我们没有一个现实的任务,例如调整图像大小或者呈现PDF文档,所以让我们 使用sleep()函数来假装这个任务是一个耗时较长的复杂任务.我........