## 綁定（Bindings） 在上一個教程中，我們已經使用過綁定。你可能會記得如下代碼： ~~~java channel.queueBind(queueName, EXCHANGE_NAME, ""); ~~~ 綁定是建立交換器和隊列之間的關系。這可以簡單地理解：隊列對該交換器上的消息感興趣。 為了避免與 basicPublish 方法的參數混淆，我們將其稱為**綁定鍵**。下面是我們如何用一個綁定鍵創建一個綁定： ~~~java channel.queueBind(queueName, EXCHANGE_NAME, "black"); ~~~ 綁定鍵的意義依賴于交換器的類型。以前我們以前使用的 fanout 類型的交換器可以忽略此參數。 ## 直接交換（Direct exchange） 我們從上一個教程的日志記錄系統向所有消費者廣播所有消息。現在，我們需要一個將錯誤日志消息寫入磁盤，而不會把硬盤空間浪費警告或消息類型日志消息上。 [](https://gitee.com/chenssy/blog-home/raw/master/image/201810/rabbitmq_direct-exchange.png) 其中，第一個隊列與綁定鍵 orange 綁定，第二個隊列有兩個綁定，一個綁定鍵為 black，另一個綁定為 green。在這樣的設置中，具有 orange 的交換器的消息將被路由到隊列 Q1。具有 black 或 green 的交換器的消息將轉到 Q2。所有其他消息將被丟棄。 ## 多重綁定（Multiple bindings） [](https://gitee.com/chenssy/blog-home/raw/master/image/201810/rabbitmq_direct-exchange-multiple.png) 此外，使用相同的綁定鍵綁定多個隊列是完全合法的。在我們的示例中，我們可以在 X 和 Q1 之間添加綁定鍵 black。在這種情況下，direct 類型的交換器將消息廣播到所有匹配的隊列 Q1 和 Q2。 ## 發送日志（Emitting logs） 我們將使用 direct 類型的交換器進行日志記錄系統。 ~~~java channel.exchangeDeclare(EXCHANGE_NAME, "direct"); ~~~ 現在，我們準備發送一條消息： ~~~java channel.basicPublish(EXCHANGE_NAME, severity, null, message.getBytes()); ~~~ 為了簡化代碼，我們假定 ‘severity’ 是 ‘info’， ‘warning’， ‘error’ 中的一個。 ## 訂閱（Subscribing） 接收消息將像上一個教程一樣工作，除了一個例外 – 我們給我們所感興趣的嚴重性類型的日志創建一個綁定。 ~~~java String queueName = channel.queueDeclare().getQueue(); for(String severity : argv){ channel.queueBind(queueName, EXCHANGE_NAME, severity); } ~~~ ## 案例實戰 [](https://gitee.com/chenssy/blog-home/raw/master/image/201810/rabbitmq_python-four.png) ### 發送端 發送端，連接到 RabbitMQ，發送一條數據，然后退出。 ~~~java public class EmitLogDirect { private static final String EXCHANGE_NAME = "direct_logs"; private static final String[] LOG_LEVEL_ARR = {"debug", "info", "error"}; public static void main(String[] args) throws IOException, TimeoutException { // 創建連接 ConnectionFactory factory = new ConnectionFactory(); // 設置 RabbitMQ 的主機名 factory.setHost("localhost"); // 創建一個連接 Connection connection = factory.newConnection(); // 創建一個通道 Channel channel = connection.createChannel(); // 指定一個交換器 channel.exchangeDeclare(EXCHANGE_NAME, "direct"); // 發送消息 for (int i = 0; i < 10; i++) { int rand = new Random().nextInt(3); String severity = LOG_LEVEL_ARR[rand]; String message = "Liang-MSG log : [" +severity+ "]" + UUID.randomUUID().toString(); // 發布消息至交換器 channel.basicPublish(EXCHANGE_NAME, severity, null, message.getBytes()); System.out.println(" [x] Sent '" + message + "'"); } // 關閉頻道和連接 channel.close(); connection.close(); } } ~~~ ### 接受端 接受端，不斷等待服務器推送消息，然后在控制臺輸出。 ~~~java public class ReceiveLogsDirect { private static final String EXCHANGE_NAME = "direct_logs"; private static final String[] LOG_LEVEL_ARR = {"debug", "info", "error"}; public static void main(String[] args) throws IOException, TimeoutException { // 創建連接 ConnectionFactory factory = new ConnectionFactory(); // 設置 RabbitMQ 的主機名 factory.setHost("localhost"); // 創建一個連接 Connection connection = factory.newConnection(); // 創建一個通道 Channel channel = connection.createChannel(); // 指定一個交換器 channel.exchangeDeclare(EXCHANGE_NAME, "direct"); // 設置日志級別 int rand = new Random().nextInt(3); String severity = LOG_LEVEL_ARR[rand]; // 創建一個非持久的、唯一的、自動刪除的隊列 String queueName = channel.queueDeclare().getQueue(); // 綁定交換器和隊列 // queueBind(String queue, String exchange, String routingKey) // 參數1 queue ：隊列名 // 參數2 exchange ：交換器名 // 參數3 routingKey ：路由鍵名 channel.queueBind(queueName, EXCHANGE_NAME, severity); // 創建隊列消費者 final Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String message = new String(body, "UTF-8"); System.out.println(" [x] Received '" + message + "'"); } }; channel.basicConsume(queueName, true, consumer); } } ~~~ 現在，做一個實驗，我們開啟三個 ReceiveLogsDirect 工作程序：ReceiveLogsDirect1 、ReceiveLogsDirect2 與 ReceiveLogsDirect3。 ReceiveLogsDirect1 ~~~null [*] Waiting for messages. To exit press CTRL+C [*] LOG LEVEL : info [x] Received 'Liang-MSG log : [info]0dd0ae0c-bf74-4aa9-9852-394e65fbf939' [x] Received 'Liang-MSG log : [info]b2b032f6-e907-4c95-b676-1790204c5f73' [x] Received 'Liang-MSG log : [info]14482461-e432-4866-9eb5-a28f4edeb47f' ~~~ ReceiveLogsDirect2 ~~~null [*] Waiting for messages. To exit press CTRL+C [*] LOG LEVEL : error [x] Received 'Liang-MSG log : [error]493dce2a-7ce1-4111-953c-99ab2564a2d0' [x] Received 'Liang-MSG log : [error]2446dd80-d5f0-4d39-888f-31579b9d2724' [x] Received 'Liang-MSG log : [error]fe8219e0-5548-40ba-9810-d922d1b03dd8' [x] Received 'Liang-MSG log : [error]797b6d0e-9928-4505-9c76-56043322b1f0' ~~~ ReceiveLogsDirect3 ~~~null [*] Waiting for messages. To exit press CTRL+C [*] LOG LEVEL : debug [x] Received 'Liang-MSG log : [debug]c05eee3e-b820-4b69-9c3f-c2bbded85195' [x] Received 'Liang-MSG log : [debug]4645c9ba-4070-41d7-adc9-7f8b2df1e3c8' [x] Received 'Liang-MSG log : [debug]d3d3ad5c-8f97-49ea-8fd6-c434790e40eb' ~~~ 此時，ReceiveLogsDirect1 、ReceiveLogsDirect2 與 ReceiveLogsDirect3 同時收到了屬于自己級別的消息。 ## 源代碼 > 相關示例完整代碼：[https://github.com/lianggzone/rabbitmq-action](https://github.com/lianggzone/rabbitmq-action)