spring boot中使用RabbitMQ routing路由詳解

在上一個教程中我們創建了一個扇形（fanout）交換器。我們能把消息已廣播的形式傳遞給多個消費者。

要做什麼？ Routing 路由

在這個教程中，添加一個新的特性，我們可以只訂閱消息的一部分。例如，將只連接我們感興趣的顏色（"orange", "black", "green"），並且把消息全部打印在控制台上。

綁定

交換器和隊列是一種綁定關係。簡單的理解為：隊列對來自這個交換器中的信息感興趣。

綁定可以加上一個額外的參數routingKey。 Spring-amqp使用通俗易懂的API（建造者模式）使它們之間的關係非常清晰。把交換器和隊列放入BindingBuilder中並可以很容易的把隊列用路由鍵（routingKey）綁定到交換器上。

 @Beanpublic Binding binding0a(DirectExchange directExchange, Queue autoDeleteQueue0) { return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("orange");}

這個意味著，綁定鍵依賴交換器類型，fanout交換器就不行沒有可以綁定的選項。

直連交換器

前一個教程中我們的消息系統是以廣播的形式傳遞給所有的消費者。我們想要擴展一下功能，加入基於顏色類型的過濾器。例如，我們想要程序一個接收詳細的錯誤消息並寫入硬盤作為日誌，不接收Info或者警告日誌。

1. fanout交換器不能實現這個操作，因為它只能笨笨的廣播。
2. 我們使用直連direct交換器替代。直連交換器背後的路由算法很簡單，綁定的鍵要精確匹配消息的路由鍵後，這個消息才能進入隊列中。

橙色、黑色、綠色三種路由鍵

如上圖，直連交換器x上綁定了2個隊列。第一個隊列使用路由鍵是orange，第二個有2個路由鍵，black和green。

在這個設定中，把一個使用路由鍵為orange的消息推送到交換器上時，那麼這個消息將會被路由到隊列Q1上。消息使用的路由鍵是black或者green時將會被路由到Q2。其餘沒有使用路由鍵的消息將會被丟棄。

並聯綁定

並聯綁定

這個可以實現類似fanout交換器的功能。

差不多了，看代碼

Config.java

 package com.zb.rabbitMQtest.t4routing.config;import org.springframework.amqp.core.*;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;/** * @author 張博*/@Configuration(value = "t4Config")public class Config { /** * 創建人：張博* 時間：2018/3/5 上午10:45 * @apiNote 定義直連交換器*/ @Bean public DirectExchange directExchange() { return new DirectExchange("direct-exchange"); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @apiNote 定義自動刪除匿名隊列*/ @Bean public Queue autoDeleteQueue0() { return new AnonymousQueue(); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @apiNote 定義自動刪除匿名隊列*/ @Bean public Queue autoDeleteQueue1() { return new AnonymousQueue(); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @param directExchange 直連交換器* @param autoDeleteQueue0 自動刪除隊列* @apiNote 綁定使用路由鍵為orange 的autoDeleteQueue0 隊列到直連交換器上* @return Binding */ @Bean public Binding binding0a(DirectExchange directExchange, Queue autoDeleteQueue0) { return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("orange"); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @param directExchange 直連交換器* @param autoDeleteQueue0 自動刪除隊列* @apiNote 綁定使用路由鍵為black 的autoDeleteQueue0 隊列到直連交換器上* @return Binding */ @Bean public Binding binding0b(DirectExchange directExchange, Queue autoDeleteQueue0) { return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("black"); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @param directExchange 直連交換器* @param autoDeleteQueue1 自動刪除隊列* @apiNote 綁定使用路由鍵為black 的autoDeleteQueue1 隊列到直連交換器上* @return Binding */ @Bean public Binding binding1a(DirectExchange directExchange, Queue autoDeleteQueue1) { return BindingBuilder.bind(autoDeleteQueue1).to(directExchange).with("black"); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @param directExchange 直連交換器* @param autoDeleteQueue1 自動刪除隊列* @apiNote 綁定使用路由鍵為green 的autoDeleteQueue1 隊列到直連交換器上* @return Binding */ @Bean public Binding binding1b(DirectExchange directExchange, Queue autoDeleteQueue1) { return BindingBuilder.bind(autoDeleteQueue1).to(directExchange).with("green"); }}

Receiver.java

 package com.zb.rabbitMQtest.t4routing.receiver;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;/** * @author 張博*/@Component(value = "t4Receiver")public class Receiver { @RabbitListener(queues = "#{autoDeleteQueue0.name}") public void receiver0(String str) { System.out.println("receiver0++++++++++:" + str); } @RabbitListener(queues = "#{autoDeleteQueue1.name}") public void receiver1(String str) { System.out.println("receiver1++++++++++:" + str); }}

Send.java

 package com.zb.rabbitMQtest.t4routing.send;import org.springframework.amqp.core.DirectExchange;import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;/** * @author 張博【[email protected]】 */@Component(value = "t4Send")public class Send { @Autowired private DirectExchange directExchange; @Autowired private RabbitTemplate rabbitTemplate; private String[] keys = {"orange", "black", "green"}; public void send() { String message = "哈哈哈"; for (int i = 0; i < 5; i++) { System.out.println("send++++++++++:".concat(message)); rabbitTemplate.convertAndSend(directExchange.getName(), keys[2], message); } }}

SendTest.java

 package com.zb.rabbitMQtest.t4routing.send;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringRunner;/** * @author 張博*/@RunWith(SpringRunner.class)@SpringBootTestpublic class SendTest { @Autowired private Send send; @Test public void send() throws Exception { send.send(); }}

測試結果，如果是keys[0]那麼只有receiver0，如果是keys[1]那麼就是類似廣播那樣，有receive0和receive1，如果是keys[2]那麼只有receive1

當keys[0]時
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈

當keys[1]時
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver0++++++++++:哈哈哈

當keys[2]時
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。