spring boot中使用RabbitMQ routing路由詳解
在上一個(gè)教程中我們創(chuàng)建了一個(gè)扇形（fanout）交換器。我們能把消息已廣播的形式傳遞給多個(gè)消費(fèi)者。
要做什么？Routing 路由
在這個(gè)教程中，添加一個(gè)新的特性，我們可以只訂閱消息的一部分。例如，將只連接我們感興趣的顏色（"orange", "black", "green"），并且把消息全部打印在控制臺(tái)上。
綁定
交換器和隊(duì)列是一種綁定關(guān)系。簡(jiǎn)單的理解為：隊(duì)列對(duì)來自這個(gè)交換器中的信息感興趣。
綁定可以加上一個(gè)額外的參數(shù)routingKey。Spring-amqp使用通俗易懂的API（建造者模式）使它們之間的關(guān)系非常清晰。把交換器和隊(duì)列放入BindingBuilder中并可以很容易的把隊(duì)列用路由鍵（routingKey）綁定到交換器上。
@Bean
public Binding binding0a(DirectExchange directExchange, Queue autoDeleteQueue0) {
return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("orange");
}
這個(gè)意味著，綁定鍵依賴交換器類型，fanout交換器就不行沒有可以綁定的選項(xiàng)。
直連交換器
前一個(gè)教程中我們的消息系統(tǒng)是以廣播的形式傳遞給所有的消費(fèi)者。我們想要擴(kuò)展一下功能，加入基于顏色類型的過濾器。例如，我們想要程序一個(gè)接收詳細(xì)的錯(cuò)誤消息并寫入硬盤作為日志，不接收Info或者警告日志。
- fanout交換器不能實(shí)現(xiàn)這個(gè)操作，因?yàn)樗荒鼙勘康膹V播。
- 我們使用直連direct交換器替代。直連交換器背后的路由算法很簡(jiǎn)單，綁定的鍵要精確匹配消息的路由鍵后，這個(gè)消息才能進(jìn)入隊(duì)列中。
橙色、黑色、綠色三種路由鍵
如上圖，直連交換器x上綁定了2個(gè)隊(duì)列。第一個(gè)隊(duì)列使用路由鍵是orange，第二個(gè)有2個(gè)路由鍵，black和green。
在這個(gè)設(shè)定中，把一個(gè)使用路由鍵為orange的消息推送到交換器上時(shí)，那么這個(gè)消息將會(huì)被路由到隊(duì)列Q1上。消息使用的路由鍵是black或者green時(shí)將會(huì)被路由到Q2。其余沒有使用路由鍵的消息將會(huì)被丟棄。
并聯(lián)綁定
并聯(lián)綁定
這個(gè)可以實(shí)現(xiàn)類似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 {
/**
* 創(chuàng)建人：張博
* 時(shí)間：2018/3/5 上午10:45
* @apiNote 定義直連交換器
*/
@Bean
public DirectExchange directExchange() {
return new DirectExchange("direct-exchange");
}
/**
* 創(chuàng)建人：張博
* 時(shí)間：2018/3/5 上午10:48
* @apiNote 定義自動(dòng)刪除匿名隊(duì)列
*/
@Bean
public Queue autoDeleteQueue0() {
return new AnonymousQueue();
}
/**
* 創(chuàng)建人：張博
* 時(shí)間：2018/3/5 上午10:48
* @apiNote 定義自動(dòng)刪除匿名隊(duì)列
*/
@Bean
public Queue autoDeleteQueue1() {
return new AnonymousQueue();
}
/**
* 創(chuàng)建人：張博
* 時(shí)間：2018/3/5 上午10:48
* @param directExchange 直連交換器
* @param autoDeleteQueue0 自動(dòng)刪除隊(duì)列
* @apiNote 綁定使用路由鍵為 orange 的 autoDeleteQueue0 隊(duì)列到直連交換器上
* @return Binding
*/
@Bean
public Binding binding0a(DirectExchange directExchange, Queue autoDeleteQueue0) {
return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("orange");
}
/**
* 創(chuàng)建人：張博
* 時(shí)間：2018/3/5 上午10:48
* @param directExchange 直連交換器
* @param autoDeleteQueue0 自動(dòng)刪除隊(duì)列
* @apiNote 綁定使用路由鍵為 black 的 autoDeleteQueue0 隊(duì)列到直連交換器上
* @return Binding
*/
@Bean
public Binding binding0b(DirectExchange directExchange, Queue autoDeleteQueue0) {
return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("black");
}
/**
* 創(chuàng)建人：張博
* 時(shí)間：2018/3/5 上午10:48
* @param directExchange 直連交換器
* @param autoDeleteQueue1 自動(dòng)刪除隊(duì)列
* @apiNote 綁定使用路由鍵為 black 的 autoDeleteQueue1 隊(duì)列到直連交換器上
* @return Binding
*/
@Bean
public Binding binding1a(DirectExchange directExchange, Queue autoDeleteQueue1) {
return BindingBuilder.bind(autoDeleteQueue1).to(directExchange).with("black");
}
/**
* 創(chuàng)建人：張博
* 時(shí)間：2018/3/5 上午10:48
* @param directExchange 直連交換器
* @param autoDeleteQueue1 自動(dòng)刪除隊(duì)列
* @apiNote 綁定使用路由鍵為 green 的 autoDeleteQueue1 隊(duì)列到直連交換器上
* @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 張博【zhangb@lianliantech.cn】
*/
@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)
@SpringBootTest
public class SendTest {
@Autowired
private Send send;
@Test
public void send() throws Exception {
send.send();
}
}
測(cè)試結(jié)果，如果是keys[0]那么只有receiver0，如果是keys[1]那么就是類似廣播那樣，有receive0和receive1，如果是keys[2]那么只有receive1
當(dāng)keys[0]時(shí)
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈當(dāng)keys[1]時(shí)
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver0++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver0++++++++++:哈哈哈當(dāng)keys[2]時(shí)
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
send++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
receiver1++++++++++:哈哈哈
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了這一次搞懂Spring事務(wù)是如何傳播的，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-08-08
Eclipse是用java的同行必不可少的工具，我總結(jié)了一下它的快捷鍵，太常用的ctrl+單擊、ctrl+shift+F、Ctrl+1等我就不細(xì)說了，主要是方便查看。下邊小編就詳細(xì)的為大家介紹一下2013-07-07
這篇文章主要介紹了Java高階語(yǔ)法Volatile，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03
這篇文章主要介紹了Java編程—在測(cè)試中考慮多態(tài)，具有一定參考價(jià)值，需要的朋友可以了解下。2017-11-11
DoytoQuery中關(guān)于N+1查詢問題解決方案詳解
這篇文章主要為大家介紹了DoytoQuery中關(guān)于N+1查詢問題解決方案詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-12-12
在項(xiàng)目開發(fā)過程中插件調(diào)試非常的麻煩，需要修改里面的代碼，編譯出class，需要重新打包插件。然后把之前的刪除，重新安裝最新的。調(diào)試過程比較繁瑣，而且不能調(diào)試，十分的不方便，這篇文章主要介紹的是調(diào)試報(bào)表插件的方法,需要的朋友可以參考下2015-07-07
java實(shí)現(xiàn)的計(jì)算器功能示例【基于swing組件】
這篇文章主要介紹了java實(shí)現(xiàn)的計(jì)算器功能,結(jié)合實(shí)例形式分析了java基于swing組件實(shí)現(xiàn)計(jì)算器功能相關(guān)運(yùn)算操作技巧,需要的朋友可以參考下2017-12-12
SpringCloud實(shí)戰(zhàn)小貼士之Zuul的路徑匹配
這篇文章主要介紹了SpringCloud實(shí)戰(zhàn)小貼士之Zuul的路徑匹配,小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-10-10
Jlabel實(shí)現(xiàn)內(nèi)容自動(dòng)換行簡(jiǎn)單實(shí)例
這篇文章主要介紹了Jlabel實(shí)現(xiàn)內(nèi)容自動(dòng)換行簡(jiǎn)單實(shí)例，具有一定借鑒價(jià)值,需要的朋友可以參考下2018-01-01
基于Java SSM實(shí)現(xiàn)在線點(diǎn)餐系統(tǒng)
本項(xiàng)目基于Java SSM框架實(shí)現(xiàn)在線點(diǎn)餐系統(tǒng)，主要實(shí)現(xiàn)系統(tǒng)的在線點(diǎn)餐功能。文中的示例代碼講解詳細(xì)，感興趣的可以跟隨小編一起學(xué)習(xí)一下2022-02-02