//宣告直連交換器

channel.exchangeDeclare(EXCHANGE_NAME, "direct");  

// 獲取匿名佇列名稱  

String queueName = channel.queueDeclare().getQueue();



根據路由關鍵字進行多重繫結 

for(String severity :routingKeys){  

        channel.queueBind(queueName, EXCHANGE_NAME, severity);  

} 



//消費資料

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 '" + envelope.getRoutingKey() + "':'"
 
 + message + "'");  

            }  

  };  

        channel.basicConsume(queueName, true, consumer);

直連型別交換器

上一章的例子是通過分發【fanout】型別的交換器【logs】廣播日誌資訊，現在我們將日誌分debug、info、warn、error這幾種基本的級別，實際在生產環境中，避免磁碟空間浪費，應用只會將error級別的日誌打印出來。而分發【fanout】型別的交換器會將所有基本的日誌都發送出來，如果我們想只接收某一級別的日誌資訊，就需要使用直連【direct】型別的交換器了, 下面的圖中，佇列1通過ERROR這個routingkey繫結到E交換器，佇列2通過WARN和INFO繫結到E交換器，E交換器的型別是直連【direct】的，如果生產者【P】發出ERROR的日誌，只會有佇列1會收到，如果生產者【P】發出INFO和WARN的日誌，只有佇列2會收到，如果生產者【P】發出DEBUG級別的日誌，佇列1和佇列2都會忽略它。

多重繫結

我們允許多個佇列以相同的路由關鍵字繫結到同一個交換器中，可以看到，交換器雖然是直連型別，但是繫結後的效果卻跟分發型別的交換器類似，相同的是佇列1和佇列2都會收到同一條來自交換器的訊息。

他們的區別：分發模式下，佇列1、佇列2會收到所有級別（除ERROR級別以外）的訊息，而直連模式下，他們僅僅只會收到ERROR關鍵字型別的訊息。