上一篇部落格我們建立了一個簡單的日誌系統，我們能夠廣播日誌訊息給所有你的接收者，如果你不瞭解，請檢視：RabbitMQ （三） 釋出/訂閱。本篇部落格我們準備給日誌系統新增新的特性，讓日誌接收者能夠訂閱部分訊息。例如，我們可以僅僅將致命的錯誤寫入日誌檔案，然而仍然在控制面板上打印出所有的其他型別的日誌訊息。

1、繫結（Bindings）

在上一篇部落格中我們已經使用過繫結。類似下面的程式碼：
channel.queueBind(queueName, EXCHANGE_NAME, "");
繫結表示轉發器與佇列之間的關係。我們也可以簡單的認為：佇列對該轉發器上的訊息感興趣。
繫結可以附帶一個額外的引數routingKey。為了與避免basicPublish方法（釋出訊息的方法）的引數混淆，我們準備把它稱作繫結鍵（binding key）。下面展示如何使用繫結鍵（binding key）來建立一個繫結：
channel.queueBind(queueName, EXCHANGE_NAME, "black");
繫結鍵的意義依賴於轉發器的型別。對於fanout型別，忽略此引數。

2、直接轉發（Direct exchange）

上一篇的日誌系統廣播所有的訊息給所有的消費者。我們希望可以對其擴充套件，來允許根據日誌的嚴重性進行過濾日誌。例如：我們可能希望把致命型別的錯誤寫入硬碟，而不把硬碟空間浪費在警告或者訊息型別的日誌上。
之前我們使用fanout型別的轉發器，但是並沒有給我們帶來更多的靈活性：僅僅可以愚蠢的轉發。
我們將會使用direct型別的轉發器進行替代。direct型別的轉發器背後的路由轉發演算法很簡單：訊息會被推送至繫結鍵（binding key）和訊息釋出附帶的選擇鍵（routing key）完全匹配的佇列。
圖解：

上圖，我們可以看到direct型別的轉發器與兩個佇列繫結。第一個佇列與繫結鍵orange繫結，第二個佇列與轉發器間有兩個繫結，一個與繫結鍵black繫結，另一個與green繫結鍵繫結。
這樣的話，當一個訊息附帶一個選擇鍵（routing key） orange釋出至轉發器將會被導向到佇列Q1。訊息附帶一個選擇鍵（routing key）black或者green將會被導向到Q2.所有的其他的訊息將會被丟棄。

3、多重繫結（multiple bindings）

使用一個繫結鍵（binding key）繫結多個佇列是完全合法的。如上圖，一個附帶選擇鍵（routing key）的訊息將會被轉發到Q1和Q2。

4、傳送日誌（Emittinglogs）

我們準備將這種模式用於我們的日誌系統。我們將訊息傳送到direct型別的轉發器而不是fanout型別。我們將把日誌的嚴重性作為選擇鍵（routing key）。這樣的話，接收程式可以根據嚴重性來選擇接收。我們首先關注傳送日誌的程式碼：

像以前一樣，我們需要先建立一個轉發器：

channel.exchangeDeclare(EXCHANGE_NAME,"direct");

然後我們準備傳送一條訊息：

channel.basicPublish(EXCHANGE_NAME,severity, null, message.getBytes());

為了簡化程式碼，我們假定‘severity’是‘info’，‘warning’，‘error’中的一個。

5、訂閱

接收訊息的程式碼和前面的部落格的中類似，只有一點不同：我們給我們所感興趣的嚴重性型別的日誌建立一個繫結。

StringqueueName = channel.queueDeclare().getQueue();

for(Stringseverity : argv)

{

channel.queueBind(queueName, EXCHANGE_NAME, severity);

}

6、完整的例項

傳送端：EmitLogDirect.java

package com.zhy.rabbit._04_binding_key;import java.util.Random;import java.util.UUID;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;public class EmitLogDirect{ private static final String EXCHANGE_NAME = "ex_logs_direct"; private static final String[] SEVERITIES = { "info", "warning", "error" }; public static void main(String[] argv) throws java.io.IOException {  // 建立連線和頻道  ConnectionFactory factory = new ConnectionFactory();  factory.setHost("localhost");  Connection connection = factory.newConnection();  Channel channel = connection.createChannel();  // 宣告轉發器的型別  channel.exchangeDeclare(EXCHANGE_NAME, "direct");  //傳送6條訊息  for (int i = 0; i < 6; i++)  {   String severity = getSeverity();   String message = severity + "_log :" + UUID.randomUUID().toString();   // 釋出訊息至轉發器，指定routingkey   channel.basicPublish(EXCHANGE_NAME, severity, null, message     .getBytes());   System.out.println(" [x] Sent '" + message + "'");  }  channel.close();  connection.close(); } /**  * 隨機產生一種日誌型別  *   * @return  */ private static String getSeverity() {  Random random = new Random();  int ranVal = random.nextInt(3);  return SEVERITIES[ranVal]; }}

隨機發送6條隨機型別（routing key）的日誌給轉發器~~接收端：ReceiveLogsDirect.java

package com.zhy.rabbit._04_binding_key;import java.util.Random;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;import com.rabbitmq.client.QueueingConsumer;public class ReceiveLogsDirect{ private static final String EXCHANGE_NAME = "ex_logs_direct"; private static final String[] SEVERITIES = { "info", "warning", "error" }; public static void main(String[] argv) throws java.io.IOException,   java.lang.InterruptedException {  // 建立連線和頻道  ConnectionFactory factory = new ConnectionFactory();  factory.setHost("localhost");  Connection connection = factory.newConnection();  Channel channel = connection.createChannel();  // 宣告direct型別轉發器  channel.exchangeDeclare(EXCHANGE_NAME, "direct");  String queueName = channel.queueDeclare().getQueue();  String severity = getSeverity();  // 指定binding_key  channel.queueBind(queueName, EXCHANGE_NAME, severity);  System.out.println(" [*] Waiting for "+severity+" logs. To exit press CTRL+C");  QueueingConsumer consumer = new QueueingConsumer(channel);  channel.basicConsume(queueName, true, consumer);  while (true)  {   QueueingConsumer.Delivery delivery = consumer.nextDelivery();   String message = new String(delivery.getBody());   System.out.println(" [x] Received '" + message + "'");  } } /**  * 隨機產生一種日誌型別  *   * @return  */ private static String getSeverity() {  Random random = new Random();  int ranVal = random.nextInt(3);  return SEVERITIES[ranVal]; }}

接收端隨機設定一個日誌嚴重級別（binding_key）。。。我開啟了3個接收端程式，兩個準備接收error型別日誌，一個接收info型別日誌，然後執行傳送端程式執行結果： [x] Sent 'error_log :d142b096-46c0-4380-a1d2-d8b2ac136a9c'
 [x] Sent 'error_log :55ee1fc4-c87c-4e5e-81ba-49433890b9ce'
 [x] Sent 'error_log :d01877d6-87c7-4e0a-a109-697d122bc4c9'
 [x] Sent 'error_log :b42471b1-875c-43f1-b1ea-0dd5b49863f3'
 [x] Sent 'info_log :a6c1bc87-efb0-43eb-8314-8a74c345ed05'
 [x] Sent 'info_log :b6a84b6a-353e-4e88-8c23-c791d93b44be'
------------------------------------------------------------------------------------ [*] Waiting for error logs. To exit press CTRL+C
 [x] Received 'error_log :d142b096-46c0-4380-a1d2-d8b2ac136a9c'
 [x] Received 'error_log :55ee1fc4-c87c-4e5e-81ba-49433890b9ce'
 [x] Received 'error_log :d01877d6-87c7-4e0a-a109-697d122bc4c9'
 [x] Received 'error_log :b42471b1-875c-43f1-b1ea-0dd5b49863f3'
------------------------------------------------------------------------------------
 [*] Waiting for error logs. To exit press CTRL+C
 [x] Received 'error_log :d142b096-46c0-4380-a1d2-d8b2ac136a9c'
 [x] Received 'error_log :55ee1fc4-c87c-4e5e-81ba-49433890b9ce'
 [x] Received 'error_log :d01877d6-87c7-4e0a-a109-697d122bc4c9'
 [x] Received 'error_log :b42471b1-875c-43f1-b1ea-0dd5b49863f3'
------------------------------------------------------------------------------------
 [*] Waiting for info logs. To exit press CTRL+C
 [x] Received 'info_log :a6c1bc87-efb0-43eb-8314-8a74c345ed05'
 [x] Received 'info_log :b6a84b6a-353e-4e88-8c23-c791d93b44be'
可以看到我們實現了博文開頭所描述的特性，接收者可以自定義自己感興趣型別的日誌。其實文章這麼長就在說：傳送訊息時可以設定routing_key，接收佇列與轉發器間可以設定binding_key，接收者接收與binding_key與routing_key相同的訊息。