SpringBoot中使用 RabbitMQ的教程詳解

更新時(shí)間：2020年11月16日 10:09:58 作者：kongfanyu

這篇文章主要介紹了SpringBoot中使用 RabbitMQ的教程詳解,本文通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

本章主要建立在已經(jīng)安裝好Erlang以及RabbitMQ的基礎(chǔ)上，接下來(lái)，簡(jiǎn)單介紹一下使用

一、Direct直接模式

通過(guò)routingKey和exchange決定的那個(gè)唯一的queue可以接收消息

在這里插入圖片描述

1、首先到RabbitMQ的管理界面新建一個(gè)隊(duì)列（Direct模式）

在這里插入圖片描述

2、測(cè)試項(xiàng)目的基礎(chǔ)結(jié)構(gòu)如下：

這里為了方便測(cè)試，直接在父項(xiàng)目中建立兩個(gè)子模塊（生產(chǎn)者和消費(fèi)者）

在這里插入圖片描述

3、pom.xml文件的依賴(lài)如下：

父項(xiàng)目：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <packaging>pom</packaging>
 <modules>
  <module>rab-consumer</module>
  <module>rab-producer</module>
 </modules>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.0.7.RELEASE</version>
  <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <groupId>interview</groupId>
 <artifactId>rabbitmq-interview</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>rabbitmq-interview</name>
 <description>Demo rabbitmq project for Spring Boot</description>

 <properties>
  <java.version>1.8</java.version>
 </properties>

 <dependencies>
  <!--1、amqp高級(jí)消息隊(duì)列的依賴(lài)-->
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-amqp</artifactId>
  </dependency>
		<!--2、測(cè)試的依賴(lài)-->
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
  </dependency>
  <dependency>
   <groupId>org.springframework.amqp</groupId>
   <artifactId>spring-rabbit-test</artifactId>
   <scope>test</scope>
  </dependency>
 </dependencies>

 <build>
  <plugins>
   <plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
   </plugin>
  </plugins>
 </build>

</project>

4、準(zhǔn)備發(fā)送的數(shù)據(jù)

回到IDEA中，打開(kāi)子模塊的生產(chǎn)者模塊，我這邊是rab_producer，在resource下建立springboot的配置文件：application.yml文件，內(nèi)容如下：

spring:
 rabbitmq:
 host: localhost
# host 為RabbitMQ主機(jī)的地址

之后新建一個(gè)SpringBoot的啟動(dòng)類(lèi)：

@SpringBootApplication
public class RabbitMQApplication {
 public static void main(String[] args) {
  SpringApplication.run(RabbitMQApplication.class);
 }
}

然后新建測(cè)試類(lèi)：

@RunWith(SpringRunner.class) // 固定寫(xiě)法
@SpringBootTest(classes = RabbitMQApplication.class) // SpringBoot啟動(dòng)類(lèi)（自定義的）
public class RabTest {
 @Autowired
 private RabbitTemplate rabbitTemplate; // 注入一個(gè)RabbitMQ的模板對(duì)象，操作消息隊(duì)列的對(duì)象

 // 發(fā)送一條點(diǎn)對(duì)點(diǎn)（Direct）的消息，又稱(chēng)為直連
 @Test
 public void sendQueue(){
  System.out.println("開(kāi)始向隊(duì)列中發(fā)送一條消息！");
  // 參數(shù)1：管理中的隊(duì)列名 參數(shù)2：發(fā)送的消息
  rabbitTemplate.convertAndSend("weiku","message:這是一條消息！");
  System.out.println("消息發(fā)送完畢！");
 }
}

運(yùn)行測(cè)試方法即可把消息發(fā)送到隊(duì)列（weiku）中。

如果消息未被消費(fèi)，可在管理界面查看到：

在這里插入圖片描述

3、準(zhǔn)備消費(fèi)者接收消息

回到IDEA中，打開(kāi)子模塊的消費(fèi)者模塊，我這邊是rab_consumer，在子模塊中創(chuàng)建一個(gè)啟動(dòng)類(lèi)，內(nèi)容如下：

在這里插入圖片描述

@SpringBootApplication
public class RabbitMQApplication {
 public static void main(String[] args) {
  SpringApplication.run(RabbitMQApplication.class);
 }
}

完成之后，定義一個(gè)接收消息的監(jiān)聽(tīng)器，并且注入到Spring容器中，代碼如下：

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku") // 指定監(jiān)聽(tīng)的隊(duì)列名
public class Consumer1 {
 @RabbitHandler // 消息接收處理
 public void showMSG(String message){ // 得到我們producer中發(fā)送的Object數(shù)據(jù)，此處可根據(jù)傳過(guò)來(lái)的類(lèi)型來(lái)選擇接收，否則拋出異常
  System.out.println("weiku收到的消息內(nèi)容為：" + message);
 }
}

準(zhǔn)備完成之后，運(yùn)行啟動(dòng)類(lèi)可接收到我們剛剛發(fā)送的Direct點(diǎn)對(duì)點(diǎn)的消息，這種模式的消息只能被一個(gè)消費(fèi)者所消費(fèi)到，運(yùn)行結(jié)果如下：

在這里插入圖片描述

二、fanout廣播模式

在這里插入圖片描述

首先需要到RabbitMQ的管理界面新增一個(gè)路由交換機(jī)（Exchange）

在這里插入圖片描述

新建完路由之后，需要再新建幾個(gè)隊(duì)列，如圖：

在這里插入圖片描述

之后，還沒(méi)完，需要把我們新建路由和我們新建的隊(duì)列綁定：

在這里插入圖片描述

出現(xiàn)如圖界面：

在這里插入圖片描述

綁定完成之后，開(kāi)始代碼測(cè)試。

5、進(jìn)行發(fā)布/訂閱的代碼測(cè)試

生產(chǎn)者：

// 廣播的形式發(fā)送，同一個(gè)路由下的所有隊(duì)列都能接收到消息
@Test
public void sendFanout(){
 System.out.println("開(kāi)始向路由發(fā)送消息（路由下的所有Queue都能收到該消息）");
 // 參數(shù)1：路由名 參數(shù)2：可有可無(wú) 參數(shù)3：發(fā)送的消息內(nèi)容
 rabbitTemplate.convertAndSend("weiku-work","","這是一條所有消費(fèi)者都能收到的消息！");
 System.out.println("消息發(fā)送成功！");
}

消費(fèi)者：

消費(fèi)者1：

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku") // 指定監(jiān)聽(tīng)的隊(duì)列名
public class Consumer1 {
 @RabbitHandler // 消息接收處理
 public void showMSG(String message){ // 得到我們producer中發(fā)送的Object數(shù)據(jù)，此處可根據(jù)傳過(guò)來(lái)的類(lèi)型來(lái)選擇接收，否則拋出異常
  System.out.println("weiku收到的消息內(nèi)容為：" + message);
 }
}

消費(fèi)者2：

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku1") // 指定監(jiān)聽(tīng)的隊(duì)列名
public class Consumer2 {
 @RabbitHandler // 消息接收處理
 public void getMSG(String msg){
  System.out.println("weiku1收到的消息如下：" + msg);
 }
}

消費(fèi)者3：

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku2") // 指定監(jiān)聽(tīng)的隊(duì)列名
public class Consumer3 {
 @RabbitHandler // 消息接收處理
 public void getMSG(String msg){
  System.out.println("weiku2收到的消息如下：" + msg);
 }
}

先運(yùn)行生產(chǎn)者的測(cè)試發(fā)送消息的方法，再運(yùn)行消費(fèi)者的SpringBoot啟動(dòng)類(lèi)。

運(yùn)行結(jié)果如下：

在這里插入圖片描述

三、Topic通配符模式

topic主題模式模糊匹配，不是精確匹配。

在這里插入圖片描述

新建一個(gè)用來(lái)發(fā)送主題的路由

在這里插入圖片描述

路由新建完之后，新建3個(gè)隊(duì)列，用來(lái)接收發(fā)布的 topic，如圖：

在這里插入圖片描述

之后還需把我們新建的隊(duì)列和路由進(jìn)行綁定，如圖所示：

在這里插入圖片描述

這里的 # 代表所有類(lèi)型匹配。

以上的準(zhǔn)備完成之后，開(kāi)始代碼測(cè)試：

測(cè)試1：

生產(chǎn)者：

@Test
public void sendTopic1(){
 System.out.println("開(kāi)始向路由中發(fā)送消息！參數(shù)2：routingKey");
 // 參數(shù)1：路由器名 參數(shù)2：類(lèi)似于發(fā)送的規(guī)則名
 rabbitTemplate.convertAndSend("weiku-topic","good.log","這是一條good.log消息");
}

此處三個(gè)隊(duì)列都能接收到數(shù)據(jù)，因?yàn)槎计ヅ洹?/p>

消費(fèi)者：

消費(fèi)者1：

@Component
@RabbitListener(queues = "wk0")
public class Con1 {
 @RabbitHandler
 public void getMSG(String msg){
  System.out.println("wk0收到的消息為：" + msg);
 }
}

消費(fèi)者2：

@Component
@RabbitListener(queues = "wk1")
public class Con2 {
 @RabbitHandler
 public void getMSG(String msg){
  System.out.println("wk1收到的消息如下：" + msg);
 }
}

消費(fèi)者3：

@Component
@RabbitListener(queues = "wk2")
public class Con3 {
 @RabbitHandler
 public void getMSG(String msg){
  System.out.println("wk2收到的消息如下：" + msg);
 }

 /**
  * 可以進(jìn)行重載，會(huì)找到指定參數(shù)的queue上
  * @param map
  */
 @RabbitHandler
 public void getMSG(Map map){
  System.out.println("wk2收到的（map）消息如下：" + map);
 }
 @RabbitHandler
 public void getMSG(List list){
  System.out.println("wk2收到的（list）消息如下：" + list);
 }
}

啟動(dòng)SpringBoot，運(yùn)行結(jié)果如下：

在這里插入圖片描述

因?yàn)檫@邊3個(gè)隊(duì)列都符合了規(guī)則，所以都能消費(fèi)到消息

測(cè)試2：

生產(chǎn)者：

@Test
public void sendTopic2(){
 System.out.println("開(kāi)始向路由中發(fā)送消息！參數(shù)2：routingKey");
 rabbitTemplate.convertAndSend("weiku-topic","維護(hù).log","這是一條 維護(hù).log消息");
 rabbitTemplate.convertAndSend("weiku-topic","日志.log","這是一條 日志.log消息");
}

消費(fèi)者運(yùn)行結(jié)果：

在這里插入圖片描述

此處只有 wk1 能接收到消息，因?yàn)?wk1 符合以 . log 結(jié)尾

測(cè)試3：

生產(chǎn)者：

@Test
public void sendTopic3(){
 // 1.準(zhǔn)備發(fā)送的數(shù)據(jù)
 Map map = new HashMap();
 map.put(1,"a");
 map.put(2,"b");
 List list = new ArrayList();
 list.add("qq");
 list.add("ww");
 list.add("SS");
 System.out.println("開(kāi)始向路由中發(fā)送消息！參數(shù)2為routingKey");
 // 2.開(kāi)始發(fā)送消息（發(fā)送了2條）
 // 2.1 發(fā)送的數(shù)據(jù)為map類(lèi)型
 rabbitTemplate.convertAndSend("weiku-topic","good.txt",map);
 // 2.2 發(fā)送的數(shù)據(jù)為list類(lèi)型
 rabbitTemplate.convertAndSend("weiku-topic","good.txt",list);
}

消費(fèi)者運(yùn)行效果如下：

在這里插入圖片描述