溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要為大家展示了“spring boot中如何使用RabbitMQ routing路由”，內容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領大家一起研究并學習一下“spring boot中如何使用RabbitMQ routing路由”這篇文章吧。
要做什么？Routing 路由
在這個教程中，添加一個新的特性，我們可以只訂閱消息的一部分。例如，將只連接我們感興趣的顏色（"orange", "black", "green"），并且把消息全部打印在控制臺上。
綁定
交換器和隊列是一種綁定關系。簡單的理解為：隊列對來自這個交換器中的信息感興趣。
綁定可以加上一個額外的參數routingKey。Spring-amqp使用通俗易懂的API（建造者模式）使它們之間的關系非常清晰。把交換器和隊列放入BindingBuilder中并可以很容易的把隊列用路由鍵（routingKey）綁定到交換器上。
@Bean
public Binding binding0a(DirectExchange directExchange, Queue autoDeleteQueue0) {
return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("orange");
}這個意味著，綁定鍵依賴交換器類型，fanout交換器就不行沒有可以綁定的選項。
直連交換器
前一個教程中我們的消息系統是以廣播的形式傳遞給所有的消費者。我們想要擴展一下功能，加入基于顏色類型的過濾器。例如，我們想要程序一個接收詳細的錯誤消息并寫入硬盤作為日志，不接收Info或者警告日志。
fanout交換器不能實現這個操作，因為它只能笨笨的廣播。
我們使用直連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 張博【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();
}
}測試結果，如果是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++++++++++:哈哈哈
以上是“spring boot中如何使用RabbitMQ routing路由”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
