RabbitMq学习5-路由(Routing)

一、路由(Routing)

在前面的教程中，我们实现了一个简单的日志系统。可以把日志消息广播给多个接收者。

本篇教程中我们打算新增一个功能——使得它能够只订阅消息的一个字集。例如，我们只需要把严重的错误日志信息

写入日志文件（存储到磁盘），但同时仍然把所有的日志信息输出到控制台中

二、绑定（Bindings）

前面的例子，我们已经创建过绑定（bindings），代码如下：

$exchange->publish($message, '');

绑定（binding）是指交换器（exchange）和队列（queue）的关系。可以简单理解为：这个队列（queue）对这个交换器（exchange）的消息感兴趣。

绑定的时候可以带上一个额外的routingkey参数。为了避免与basicpublish的参数混淆，我们把它叫做binding key。以下是如何创建一个带binding key的绑定。

$exchange->publish($message, $routeKey);

binding key的含义取决于交换器（exchange）的类型。我们之前使用过的fanout类型会忽略这个值。

三、Direct类型的交换器（exchange）

我们的日志系统广播所有的消息给所有的消费者（consumers）。我们打算扩展它，使其可以能够精确的过滤消息。例如我们也许只是

希望当接收到一个严重错误的时候才把消息写入磁盘，以免浪费磁盘空间。

我们使用的fanout类型的交换器（exchange）扩展性不够——它能做的仅仅是广播。

我们将会使用direct类型的交换器（exchange）来代替。路由的算法很简单——交换器将会对binding key和routing key进行精确匹配，

从而确定消息该分发到哪个队列。

下图能够很好的描述这个场景：

RabbitMq学习5-路由(Routing)

四、Emitting logs

我们将会发送消息到一个direct exchange，把日志级别作为routing key。这样子负责处理接收的脚本就可以选择它要处理的日志级别。我们先看看触发日志。

我们需要创建一个交换器（exchange）：

$exchange->setName('direct_logs');

然后我们发送一则消息：

$exchange->publish($message, $severity);

我们先假设“severity”的值是info、warning、error中的一个。

五、订阅（Subscribing）

处理接收消息的方式和之前差不多，但是我们为每一个日志级别创建了一个新的绑定。

foreach ($severities as $item) {  
    $queue->bind($exchangeName, $item);
}

六、整合

　　1、生产者：emitlogdirect.php

?php

/**
 * PHP amqp(RabbitMQ) Demo-4
 */
$severity = count($argv) > 2 ? $argv[1] : 'info';
$message = empty($argv[2]) ? 'Hello World!' : ' ' . $argv[2];

var_dump($argv);

$connection = new AMQPConnection(array('host' => '127.0.0.1', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest'));
$connection->connect() or die("Cannot connect to the broker!\n");

$channel = new AMQPChannel($connection);

$exchange = new AMQPExchange($channel);
$exchange->setName('direct_logs');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange();

$exchange->publish($message, $severity);//发送消息

var_dump("[x] Sent $message");

$connection->disconnect();

View Code