[TOC] # 路由(Routing) > using php-amqplib 在上一節中，我們構建了一個簡單的日志系統。它能夠向多個接收器廣播消息。 在本教程中，我們將在上一節基礎上添加一個功能 - 我們將實現能夠只訂閱一部分消息。例如，我們想能夠僅將關鍵的錯誤消息保存到日志文件(以節省磁盤空間)，同時仍然能夠在控制臺打印所有日志消息。 # 綁定 在前面的例子中，我們已經創建了綁定。你能回憶之前的代碼： ~~~ $channel->queue_bind($queue_name, 'logs'); ~~~ 綁定是交換機和隊列之間的關系。可以簡單地理解為：隊列對來自綁定交換機的信息感興趣。 綁定可以占用一個額外的 routing_key 參數。為了避免與 $channel::basic_publish 參數混淆，我們將其稱為 binding key。下面就是我們如何創建一個綁定： ~~~ $binding_key = 'black'; $channel->queue_bind($queue_name, $exchange_name, $binding_key); ~~~ 綁定鍵的含義取決于交換機的類型。上一節中我們使用的 fanout 會直接忽略它的值。 # 直接交換 (Direct exchange) 我們上一節教程中的日志系統是向所有消費者廣播所有日志消息。我們希望擴展上一節中的日志系統，使其允許基于消息的嚴重性過濾消息。例如，我們可能希望將日志消息寫入磁盤的腳本僅接收嚴重錯誤消息，而不會在警告和提示信息上面浪費磁盤空間。 我們之前使用的 fanout 類型交換機，它沒有什么靈活性 - 只能廣播消息。 這里我們將使用 direct 交換機，直接交換背后的算法很簡單 - 消息將傳遞到 binding key 與消息的 routing key 完全匹配的隊列。 為了說明上面步驟，參考下面的設置：  在這設置中，我們可以看到 X exchange 上綁定了兩個隊列(Q1, Q2). 第一個隊列綁定了 binding key 為 orange, 第二個隊列綁定了兩個鍵，一個是 black另一個是 green。 在這樣的設置中，發布到交換機上息具有 orange 路由秘鑰的消息將被路由到隊列 Q1。消息具有black 或者 green 路由秘鑰的消息將會路由到Q2。其它所有的消息將會被丟棄。 # 多重綁定  使用相同的鍵綁定到多個隊列上是完全合法的。在上面的示例中，我們可以在X和Q1之間添加綁定 black。那樣的話，direct 交換機將能如 fanout 交換機一樣，在多個匹配的隊列之間廣播相同的消息。具有 black 路由鍵的消息將會被發送到Q1和Q2中。 # 發出日志 我們將使用此模型構建日志記錄系統。我們將把消息發送到 direct 類型交換機上, 而不是使用 fanout類型。我們將提供日志嚴重性作為 routing key。這樣接收消息的腳本就能夠選擇要接受消息的嚴重性進行接收。我們首先關注發送日志部分： 一如以往，我們首先要建立一個交換機： ~~~ $channel->exchange_declare('direct_logs', 'direct', false, false, false); ~~~ 然后，我們準備發送信息： ~~~ $channel->exchange_declare('direct_logs', 'direct', false, false, false); $channel->basic_publish($msg, 'direct_logs', $severity); ~~~ # 訂閱 接收消息大致和上一節教程一樣，除了一個例外 - 我們將為每個我們感興趣的消息嚴重性創建一個新的綁定。 ~~~ foreach($severities as $severity) { $channel->queue_bind($queue_name, 'direct_logs', $severity); } ~~~ # 代碼整合  emit_log_direct.php: ~~~ <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare('direct_logs', 'direct', false, false, false); $severity = isset($argv[1]) && !empty($argv[1]) ? $argv[1] : 'info'; $data = implode(' ', array_slice($argv, 2)); if(empty($data)) $data = "Hello World!"; $msg = new AMQPMessage($data); $channel->basic_publish($msg, 'direct_logs', $severity); echo " [x] Sent ",$severity,':',$data," \n"; $channel->close(); $connection->close(); ~~~ receive_logs_direct.php: ~~~ <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare('direct_logs', 'direct', false, false, false); list($queue_name, ,) = $channel->queue_declare("", false, false, true, false); $severities = array_slice($argv, 1); if(empty($severities )) { file_put_contents('php://stderr', "Usage: $argv[0] [info] [warning] [error]\n"); exit(1); } foreach($severities as $severity) { $channel->queue_bind($queue_name, 'direct_logs', $severity); } echo ' [*] Waiting for logs. To exit press CTRL+C', "\n"; $callback = function($msg){ echo ' [x] ',$msg->delivery_info['routing_key'], ':', $msg->body, "\n"; }; $channel->basic_consume($queue_name, '', false, true, false, false, $callback); while(count($channel->callbacks)) { $channel->wait(); } $channel->close(); $connection->close(); ~~~ 如果你只想將 warning 和 error (而非 info) 日志信息保存到文件中，只用打開一個控制臺鍵入: ~~~ php receive_logs_direct.php warning error > logs_from_rabbit.log ~~~ 如果你想在屏幕上看到所有的日志信息，打開一個控制臺鍵入： ~~~ php receive_logs_direct.php info warning error ~~~ 而且，例如，要發送 error 類型日志，只需要鍵入： ~~~ php emit_log_direct.php error "Run. Run. Or it will explode." ~~~ 接下來請閱讀：怎樣根據模式訂閱消息