RabbitMq的5種模式及實例解讀
更新時間：2023年09月25日 09:46:40 作者：某某灬
這篇文章主要介紹了RabbitMq的5種模式及實例解讀,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
先建一個spring boot項目，然后加入RabbitMQ的依賴就和相關配置。
在pom.xml中加入：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>在application.yml中加入配置：
spring:
#rabbitmq配置
rabbitmq:
host: 127.0.0.1
port: 5672
username: guest
password: guest
publisher-confirms: true # 開啟消息確認，這可不用管
virtual-host: /1、點對點，簡單的生產者消費者
先創(chuàng)建一個配置類：
@Configuration
public class RabbitConfig {
public final static String SIMPLE = "simple"; // 隊列名稱
@Bean
public Queue simpleQueue() { // 返回一個bean
return new Queue(SIMPLE, true, false, true);
}
}創(chuàng)建消費者和生產者：
@Component
public class SimpleRabbit {
// 簡單的點對點模式
@Autowired
RabbitTemplate rabbitTemplate;
// 生產者
public void send() throws Exception {
for (int i = 0; i < 5; i++) {
rabbitTemplate.convertAndSend(RabbitConfig.SIMPLE, "發(fā)送：" + i);
Thread.sleep(1000);
}
}
// 消費者監(jiān)聽SIMPLE隊列
@RabbitListener(queues = RabbitConfig.SIMPLE)
public void comsumer(String msg) {
System.out.println("comsumer:" + msg);
}
}然后在測試類測試一下：
@RunWith(SpringRunner.class)
@SpringBootTest
public class SimpleTest {
@Autowired
SimpleRabbit rabbit;
@Test
public void test() throws Exception {
rabbit.send();
}
}結果為：
2、工作模式（work）
工作模式和上邊的模式差不多，只是對于當前的隊列多了一個消費者：
我們只用在 SimpleRabbit類中添加一個消費者就可以完成測試：
@Component
public class SimpleRabbit {
// 簡單的點對點模式
@Autowired
RabbitTemplate rabbitTemplate;
// 生產者
public void send() throws Exception {
for (int i = 0; i < 10; i++) {
rabbitTemplate.convertAndSend(RabbitConfig.SIMPLE, "發(fā)送：" + i);
Thread.sleep(1000);
}
}
@RabbitListener(queues = RabbitConfig.SIMPLE)
public void comsumer1(String o) {
System.out.println("consumer1:" + o);
}
@RabbitListener(queues = RabbitConfig.SIMPLE)
public void comsumer2(String o) {
System.out.println("consumer2" + o);
}
}直接運行test的測試方法：
從打印數據來開，是采用輪詢的方式消費的。
3、發(fā)布/訂閱模式Publish/Subscribe
生產者是把消息發(fā)到交換機，然后交換機把數據發(fā)送到綁定的隊列上。
如果沒有隊列與之綁定，信息將會丟失，交換機不能存儲信息。消費者監(jiān)聽隊列，有就消費。
為了方便，這里的兩個隊列后邊兩個模式就一起用了。
@Configuration
public class RabbitConfig {
public final static String PUB_SUB_EXCHANGE = "pub_sub"; // 發(fā)布訂閱的交換機
public final static String QUEUE_1 = "queue_1"; //隊列1
public final static String QUEUE_2 = "queue_2"; //隊列2
@Bean("queue_1")
public Queue QUEUE_1_Queue() {
return new Queue(QUEUE_1, true, false, true);
}
@Bean("queue_2")
public Queue QUEUE_2_Queue() {
return new Queue(QUEUE_2, true, false, true);
}
@Bean("pub_sub") // 交換機
public Exchange pub_sub_Exchange(){
return ExchangeBuilder.fanoutExchange(PUB_SUB_EXCHANGE).build();
}
// 使交換機與隊列綁定
@Bean
public Binding binding_QUEUE_1(@Qualifier("queue_1") Queue queue, @Qualifier(PUB_SUB_EXCHANGE) Exchange exchange) {
// with是路由key,這模式默認為空就好
return BindingBuilder.bind(queue).to(exchange).with("").noargs();
}
@Bean
public Binding binding_QUEUE_2(@Qualifier("queue_2") Queue queue, @Qualifier(PUB_SUB_EXCHANGE) Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("").noargs();
}
}然后定義生產者和消費者：
@Component
public class FanoutRabbit {
@Autowired
RabbitTemplate template;
public void producer() {
for (int i = 0; i < 5; i++) {
// ""是路由key,應為沒有所以傳的空
template.convertAndSend(RabbitConfig.PUB_SUB_EXCHANGE, "", i);
}
}
// 隊列1的消費者
@RabbitListener(queues = RabbitConfig.QUEUE_1)
public void queues_1(Integer msg) {
System.out.println("隊列1的消費者：" + msg);
}
// 隊列1的消費者
@RabbitListener(queues = RabbitConfig.QUEUE_2)
public void queues_2(Integer msg) {
System.out.println("隊列2的消費者：" + msg);
}
}測試：
@Autowired
FanoutRabbit fanoutRabbit;
@Test
public void test1() {
fanoutRabbit.producer();
}結果：
4、routing路由模式
交換機綁定的路由key和隊列綁定的一樣時，才發(fā)送。
@Configuration
public class RabbitConfig {
public final static String ROUTING_EXCHANGE = "routing1"; // 路由的交換機
public final static String ROUTING_1 = "routing_1"; //routing隊列1
public final static String ROUTING_2 = "routing_2"; //routing隊列2
@Bean("routing_1")
public Queue OUTING_1_Queue() {
return new Queue(ROUTING_1, true, false, true);
}
@Bean("routing_2")
public Queue ROUTING_2_Queue() {
return new Queue(ROUTING_2, true, false, true);
}
@Bean("routing1")
public Exchange routingExchange(){
return ExchangeBuilder.directExchange(ROUTING_EXCHANGE).build();
}
@Bean
public Binding binding_Routing_QUEUE_1(@Qualifier(ROUTING_1) Queue queue, @Qualifier(ROUTING_EXCHANGE) Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(ROUTING_1).noargs();
}
@Bean
public Binding binding_Routing_QUEUE_2(@Qualifier(ROUTING_2) Queue queue, @Qualifier(ROUTING_EXCHANGE) Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(ROUTING_2).noargs();
}
}生產者和消費者：
@Component
public class RoutingRabbit {
@Autowired
RabbitTemplate template;
public void producer(){
for (int i = 0; i < 5; i++) {
template.convertAndSend(RabbitConfig.ROUTING_EXCHANGE, RabbitConfig.ROUTING_1,i);
}
}
// 隊列1的消費者
@RabbitListener(queues = RabbitConfig.ROUTING_1)
public void queues_1(Integer msg) {
System.out.println("隊列1的消費者：" + msg);
}
// 隊列1的消費者
@RabbitListener(queues = RabbitConfig.ROUTING_2)
public void queues_2(Integer msg) {
System.out.println("隊列2的消費者：" + msg);
}
}測試：
5、topic主題模式
設置隊列和交換機的路由key,當生產者發(fā)送消息時，知道路由key，比較有不有合適的key。有就發(fā)布到隊列上去。
public final static String TOPIC_1 = "routing_1"; //topic隊列1
public final static String TOPIC_2 = "routing_2"; //topic隊列2
@Bean(TOPIC_1)
public Queue TOPIC_1_Queue() {
return new Queue(TOPIC_1, true, false, true);
}
@Bean(TOPIC_2)
public Queue TOPIC_2_Queue() {
return new Queue(TOPIC_2, true, false, true);
}
@Bean(TOPIC_EXCHANGE)
public Exchange topicExchange(){
return ExchangeBuilder.topicExchange(TOPIC_EXCHANGE).build();
}
@Bean
public Binding binding_Topic_QUEUE_1(@Qualifier(TOPIC_1) Queue queue, @Qualifier(TOPIC_EXCHANGE) Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("aa.bb.cc").noargs();
}
@Bean
public Binding binding_Topic_QUEUE_2(@Qualifier(TOPIC_2) Queue queue, @Qualifier(TOPIC_EXCHANGE) Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("aa.#").noargs();
}生產者和消費者：
@Component
public class TopicRabbit {
@Autowired
RabbitTemplate template;
public void producer() {
for (int i = 0; i < 5; i++) {
template.convertAndSend(RabbitConfig.TOPIC_EXCHANGE, "aa.bb", i);
}
}
// 隊列1的消費者
@RabbitListener(queues = RabbitConfig.TOPIC_1)
public void queues_1(Integer msg) {
System.out.println("隊列1的消費者：" + msg);
}
// 隊列1的消費者
@RabbitListener(queues = RabbitConfig.TOPIC_2)
public void queues_2(Integer msg) {
System.out.println("隊列2的消費者：" + msg);
}
}測試結果：
隊列2的消費者：1
隊列2的消費者：0
隊列2的消費者：3
隊列2的消費者：2
隊列2的消費者：4
*號代表單個詞語
#代表多個詞語
其它的和routing沒什么區(qū)別。
總結
以上為個人經驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關文章
這篇文章主要介紹了如何在 Java中將List 轉換為 String,接下來使用Java 8 Streams Collectors api和String.join()方法將帶有逗號分隔符或自定義分隔符的集合轉換為字符串,需要的朋友可以參考下2025-04-04
今天給大家?guī)淼氖顷P于Java的相關知識,文章圍繞著如何用Java實現一個簡單的代碼生成器展開,文中有非常詳細的介紹及代碼示例,需要的朋友可以參考下2021-06-06
這篇文章主要給大家介紹了關于JVM指令使用的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-01-01
這篇文章主要介紹了Java中典型的內存泄露問題和解決方法，典型的內存泄露例子是一個沒有實現hasCode和 equals方法的Key類在HashMap中保存的情況，可以通過實現Key類的equals和hasCode方法解決這種內存泄漏問題,需要的朋友可以參考下2014-04-04
這篇文章主要給大家介紹了關于Java中將多個PDF文件合并為一個PDF的方法步驟, Java PDF合并是指將多個PDF文件合并成一個PDF文件的過程,需要的朋友可以參考下2023-09-09
這篇文章主要介紹了Spring數據庫事務的實現機制講解，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-10-10
HashSet 不保證集合的迭代順序，但允許插入 null 值，也就是說它可以將集合中的重復元素自動過濾掉，保證存儲在 HashSet 中的元素都是唯一的，這篇文章主要介紹了HashSet如何保證元素不重復(面試必問),需要的朋友可以參考下2021-12-12
這篇文章主要介紹了nacos配置文件優(yōu)先級過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-07-07
本篇文章主要通過實例對適配器模式進行了詳解，需要的朋友可以參考下2017-04-04
本篇文章主要介紹了Java多線程之死鎖的出現和解決方法，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-10-10