在上一篇部落格《RabbitMQ入門：釋出/訂閱（Publish/Subscribe）》中，我們認識了fanout型別的exchange，它是一種通過廣播方式傳送訊息的路由器，所有和exchange建立的繫結關係的佇列都會接收到訊息。但是有一些場景只需要訂閱到一部分訊息，這個時候就不能使用fanout 型別的exchange了，這個就引出來今天的“豬腳”--Direct Exchange，通過Routing Key來決定需要將訊息傳送到哪個或者哪些佇列中。

接下來請收看詳細內容：

1. Direct Exchange（直接路由器）
2. 多重繫結
3. 程式碼例項

一、Direct Exchange（直接路由器）

在上文中介紹exchange的時候，對direct exchange進行了簡單介紹，它是一種完全按照routing key（路由關鍵字）進行投遞的：當訊息中的routing key和佇列中的binding key完全匹配時，才進行會將訊息投遞到該佇列中。這裡提到了一個routing key和binding key（繫結關鍵字），是什麼東東？

1. routing key:

    在傳送訊息的時候，basicPublish的第二個引數就是routing key，由於上次是fanout 型別的exchange 進行廣播方式投遞，這個欄位不會影響投遞結果，因此我們這裡就傳入了“”，但是在direct 型別的exchange中我們就不能傳入""了，需要指定具體的關鍵字。

   

2. binding key:

   我們在前文中建立繫結關係的時候，queueBind的第三個引數就是繫結關鍵字

   

我們宣告direact exchange的時候使用：

二、多重繫結

多個佇列以相同的繫結鍵繫結到同一個路由器的情況，我們稱之為多重繫結。

工作模型為（P代表生產者，X代表路由器，紅色的Q代表隊列，C代表消費者）:

三、程式碼例項

 預備知識瞭解完了，現在來寫個程式感受下。

1. 生產者

   public class LogDirectSender {
       // exchange名字
       public static String EXCHANGE_NAME = "directExchange";
   
       
    
   public static void main(String[] args) {
           ConnectionFactory factory = new ConnectionFactory();
           factory.setHost("localhost");
           Connection connection = null;
           Channel channel = null;
           try {
               // 1.建立連線和通道
               connection = factory.newConnection();
               channel = connection.createChannel();
   
               // 2.為通道宣告direct型別的exchange
               channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);
   
               
               // 3.傳送訊息到指定的exchange,佇列指定為空,由exchange根據情況判斷需要傳送到哪些佇列
               String routingKey = "debug";
               String msg = " hello rabbitmq, I am " + routingKey;
               channel.basicPublish(EXCHANGE_NAME, routingKey, null, msg.getBytes());
               System.out.println("product send a msg: " + msg);
           } catch (IOException e) {
               e.printStackTrace();
           } catch (TimeoutException e) {
               e.printStackTrace();
           } finally {
               // 4.關閉連線
               if (channel != null) {
                   try {
                       channel.close();
                   } catch (IOException e) {
                       e.printStackTrace();
                   } catch (TimeoutException e) {
                       e.printStackTrace();
                   }
               }
   
               if (connection != null) {
                   try {
                       connection.close();
                   } catch (IOException e) {
                       e.printStackTrace();
                   }
               }
           }
   
       }
   }

   和上次部落格中生產者的區別就是黑字粗體部分：1.路由器型別改為direct 2.訊息釋出的時候指定了routing key

2. 消費者

   public class LogDirectReciver {
   
       public static void main(String[] args) {
           ConnectionFactory factory = new ConnectionFactory();
           factory.setHost("localhost");
           Connection connection = null;
           Channel channel = null;
           try {
               // 1.建立連線和通道
               connection = factory.newConnection();
               channel = connection.createChannel();
   
               // 2.為通道宣告direct型別的exchange
               channel.exchangeDeclare(LogDirectSender.EXCHANGE_NAME, BuiltinExchangeType.DIRECT);
               // 3.建立隨機名字的佇列
               String queueName = channel.queueDeclare().getQueue();
   
               // 4.建立exchange和佇列的繫結關係
                String[] bindingKeys = { "error", "info", "debug" };
   //            String[] bindingKeys = { "error" };
               for (int i = 0; i < bindingKeys.length; i++) {
                   channel.queueBind(queueName, LogDirectSender.EXCHANGE_NAME, bindingKeys[i]);
                   System.out.println(" **** LogDirectReciver keep alive ,waiting for " + bindingKeys[i]);
               }
   
               // 5.通過回撥生成消費者並進行監聽
               Consumer consumer = new DefaultConsumer(channel) {
                   @Override
                   public void handleDelivery(String consumerTag, Envelope envelope,
                           com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body) throws IOException {
   
                       // 獲取訊息內容然後處理
                       String msg = new String(body, "UTF-8");
                       System.out.println("*********** LogDirectReciver" + " get message :[" + msg + "]");
                   }
               };
               // 6.消費訊息
               channel.basicConsume(queueName, true, consumer);
   
           } catch (IOException e) {
               e.printStackTrace();
           } catch (TimeoutException e) {
               e.printStackTrace();
           }
       }
   
   }

   和上次部落格中消費者的區別就是黑字粗體部分：1.路由器型別改為direct 2.建立繫結關係的時候指定了binding key

3. 執行消費者，控制檯log列印如下：

    **** LogDirectReciver keep alive ,waiting for error
    **** LogDirectReciver keep alive ,waiting for info
    **** LogDirectReciver keep alive ,waiting for debug

   這個消費者我們視為消費者1，它會接收error,info,debug三個關鍵字的訊息。

4. 將String[] bindingKeys = { "error", "info", "debug" };改為String[] bindingKeys = { "error" };，然後再執行一次消費者。控制檯log列印如下：

    **** LogDirectReciver keep alive ,waiting for error

   這個消費者我們視為消費者2，它只會接收error 關鍵字的訊息。

5. 執行生產者，然後將String routingKey = "debug";的值分別改為“info"和"error"，然後分別執行，這樣一共執行了三次生產者

   第一次執行：
   product send a msg:  hello rabbitmq, I am debug
   
   第二次執行：
   product send a msg:  hello rabbitmq, I am info
   
   第三次執行：
   product send a msg:  hello rabbitmq, I am error

6. 再次檢視兩個消費者的控制檯log：

   消費者1：
    **** LogDirectReciver keep alive ,waiting for error
    **** LogDirectReciver keep alive ,waiting for info
    **** LogDirectReciver keep alive ,waiting for debug
   *********** LogDirectReciver get message :[ hello rabbitmq, I am debug]
   *********** LogDirectReciver get message :[ hello rabbitmq, I am info]
   *********** LogDirectReciver get message :[ hello rabbitmq, I am error]
   
   消費者2：
    **** LogDirectReciver keep alive ,waiting for error
   *********** LogDirectReciver get message :[ hello rabbitmq, I am error]

7. 檢視RabbitMQ管理頁面

   exchanges標籤頁裡面多了個direct型別的路由器。進入詳細頁面：

   有4個繫結關係，其中三個的佇列是同一個。切換到Queues標籤頁：

   有兩個臨時佇列。

8. 如果關掉消費者1和消費者2，會發現佇列自動刪除了，繫結關係也不存在了。