前一篇我們實現了消息系統的靈活配置。代替了使用扇形（fanout）交換器的配置。使用直連（direct）交換器，並且基於路由鍵後可以有選擇性接收消息的能力。
雖然使用直連交換器可以改善我們的系統，但是它仍有局限性，它不能實現多重條件的路由。
在我們的消息系統中，我們不僅想要訂閱基於路由鍵的隊列，還想訂閱基於生產消息的源。這些概念來自於Unix工具syslog。該日誌基於嚴格的(info/warn/crit...) 和容易的(auth/cron/kern...)的路由方式。我們的例子比這個要簡單。
這個例子將會給我們很大的靈活性，比如我們既想監聽來'cron'自錯誤的日誌又想監聽來自'kern'的所有日誌。
為了實現這個靈活性，我們需要知道更多關於主題交換器的內容。
主題交換器
使用主題交換器時不能採用任意寫法的路由鍵，路由鍵的形式應該是由點分割的單詞。用什麼詞都行，通常都是能表明意義的。例如"stock.usd.nyse", "nyse.vmw", "quick.orange.rabbit"。但字數大小被限制在最多255字節。
使用主題交換器定義路由鍵需要注意點2點
定義符合主題交換器的路由鍵
在這個例子中，我們將發送所有描述動物的消息。這個消息將會和由3個單詞2個點構成的路由鍵一起發送。第一個單詞是表述速度，第二個描述顏色，第三個描述種類："<speed>.<colour>.<species>"。
創建三種綁定，Q1和鍵"*.orange.*"綁定，Q2和"*.*.rabbit" 、"lazy.#"綁定。
三種綁定關係的概述為：
一個和路由鍵被設置成"quick.orange.rabbit"的消息將會被傳遞到Q1、Q2這兩個隊列中。 "lazy.orange.elephant" 也會這樣。 "quick.orange.fox"會去第一個隊列，"lazy.brown.fox"會去第二個隊列，"lazy.pink.rabbit"會去第二個隊列及時它匹配了2次綁定。 "quick.brown.fox"因為不匹配哪也去不了，會被丟棄。
那麼像"orange" 、 "quick.orange.male.rabbit"這樣的呢？因為沒有匹配到任何綁定也會被丟棄。
那麼像"lazy.orange.male.rabbit"也是四個詞的路由鍵呢？ ，由於匹配到了lazy.#這個將會被傳遞到第二個隊列中。
主題交換器的小技巧
主題交換器是牛逼的並且表現的與其它交換器相似。
代碼示例
代碼與之前的路由代碼沒啥兩樣，請看
Config.java
package com.zb.rabbitMQtest.t5topics.config;import org.springframework.amqp.core.*;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;/** * @author 張博*/@Configuration(value = "t5Config")public class Config { /** * 創建人：張博* 時間：2018/3/5 上午10:45 * @apiNote 定義主題交換器*/ @Bean public TopicExchange topicExchange() { return new TopicExchange("topic-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 topicExchange 主題交換器* @param autoDeleteQueue0 自動刪除隊列* @apiNote 綁定使用路由鍵為orange 的autoDeleteQueue0 隊列到主題交換器上* @return Binding */ @Bean public Binding binding0a(TopicExchange topicExchange, Queue autoDeleteQueue0) { return BindingBuilder.bind(autoDeleteQueue0).to(topicExchange).with("*.orange.*"); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @param topicExchange 主題交換器* @param autoDeleteQueue1 自動刪除隊列* @apiNote 綁定使用路由鍵為black 的autoDeleteQueue1 隊列到主題交換器上* @return Binding */ @Bean public Binding binding1a(TopicExchange topicExchange, Queue autoDeleteQueue1) { return BindingBuilder.bind(autoDeleteQueue1).to(topicExchange).with("*.*.rabbit"); } /** * 創建人：張博* 時間：2018/3/5 上午10:48 * @param topicExchange 主題交換器* @param autoDeleteQueue1 自動刪除隊列* @apiNote 綁定使用路由鍵為green 的autoDeleteQueue1 隊列到主題交換器上* @return Binding */ @Bean public Binding binding1b(TopicExchange topicExchange, Queue autoDeleteQueue1) { return BindingBuilder.bind(autoDeleteQueue1).to(topicExchange).with("lazy.#"); }} Receiver.java
package com.zb.rabbitMQtest.t5topics.receiver;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;/** * @author 張博*/@Component(value = "t5Receiver")public class Receiver { @RabbitListener(queues = "#{autoDeleteQueue0.name}") public void receiver0(String str) { System.out.println("receiver0++++++++++:" + str); //try { // Thread.sleep(1000); //} catch (InterruptedException e) { // e.printStackTrace(); //} } @RabbitListener(queues = "#{autoDeleteQueue1.name}") public void receiver1(String str) { System.out.println("receiver1++++++++++:" + str); //try { // Thread.sleep(1000); //} catch (InterruptedException e) { // e.printStackTrace(); //} }} Send.java
package com.zb.rabbitMQtest.t5topics.send;import org.springframework.amqp.core.TopicExchange;import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;/** * @author 張博*/@Component(value = "t5Send")public class Send { @Autowired private TopicExchange topicExchange; @Autowired private RabbitTemplate rabbitTemplate; private String[] keys = {"quick.orange.rabbit", "lazy.orange.elephant", "quick.orange.fox", "lazy.brown.fox", "lazy.pink.rabbit", "quick.brown.fox"}; public void send() { String message = "哈哈哈"; for (int i = 0; i < 5; i++) { System.out.println("send++++++++++:".concat(message)); rabbitTemplate.convertAndSend(topicExchange.getName(), keys[5], message); } }} SendTest.java
package com.zb.rabbitMQtest.t5topics.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(); }}測試結果我就不放了大家請自行查看。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。