SpringBoot中使用 RabbitMQ的教程详解

<?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高级消息队列的依赖-->
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-amqp</artifactId>
  </dependency>
		<!--2、测试的依赖-->
  <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>

spring:
 rabbitmq:
 host: localhost
# host 为RabbitMQ主机的地址

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

@RunWith(SpringRunner.class) // 固定写法
@SpringBootTest(classes = RabbitMQApplication.class) // SpringBoot启动类（自定义的）
public class RabTest {
 @Autowired
 private RabbitTemplate rabbitTemplate; // 注入一个RabbitMQ的模板对象，操作消息队列的对象

 // 发送一条点对点（Direct）的消息，又称为直连
 @Test
 public void sendQueue(){
  System.out.println("开始向队列中发送一条消息！");
  // 参数1：管理中的队列名 参数2：发送的消息
  rabbitTemplate.convertAndSend("weiku","message:这是一条消息！");
  System.out.println("消息发送完毕！");
 }
}

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

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku") // 指定监听的队列名
public class Consumer1 {
 @RabbitHandler // 消息接收处理
 public void showMSG(String message){ // 得到我们producer中发送的Object数据，此处可根据传过来的类型来选择接收，否则抛出异常
  System.out.println("weiku收到的消息内容为：" + message);
 }
}

// 广播的形式发送，同一个路由下的所有队列都能接收到消息
@Test
public void sendFanout(){
 System.out.println("开始向路由发送消息（路由下的所有Queue都能收到该消息）");
 // 参数1：路由名 参数2：可有可无 参数3：发送的消息内容
 rabbitTemplate.convertAndSend("weiku-work","","这是一条所有消费者都能收到的消息！");
 System.out.println("消息发送成功！");
}

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku") // 指定监听的队列名
public class Consumer1 {
 @RabbitHandler // 消息接收处理
 public void showMSG(String message){ // 得到我们producer中发送的Object数据，此处可根据传过来的类型来选择接收，否则抛出异常
  System.out.println("weiku收到的消息内容为：" + message);
 }
}

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku1") // 指定监听的队列名
public class Consumer2 {
 @RabbitHandler // 消息接收处理
 public void getMSG(String msg){
  System.out.println("weiku1收到的消息如下：" + msg);
 }
}

@Component // 需要注入到Spring容器中
@RabbitListener(queues = "weiku2") // 指定监听的队列名
public class Consumer3 {
 @RabbitHandler // 消息接收处理
 public void getMSG(String msg){
  System.out.println("weiku2收到的消息如下：" + msg);
 }
}

@Test
public void sendTopic1(){
 System.out.println("开始向路由中发送消息！参数2：routingKey");
 // 参数1：路由器名 参数2：类似于发送的规则名
 rabbitTemplate.convertAndSend("weiku-topic","good.log","这是一条good.log消息");
}

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

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

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

 /**
  * 可以进行重载，会找到指定参数的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);
 }
}

@Test
public void sendTopic2(){
 System.out.println("开始向路由中发送消息！参数2：routingKey");
 rabbitTemplate.convertAndSend("weiku-topic","维护.log","这是一条 维护.log消息");
 rabbitTemplate.convertAndSend("weiku-topic","日志.log","这是一条 日志.log消息");
}

@Test
public void sendTopic3(){
 // 1.准备发送的数据
 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("开始向路由中发送消息！参数2为routingKey");
 // 2.开始发送消息（发送了2条）
 // 2.1 发送的数据为map类型
 rabbitTemplate.convertAndSend("weiku-topic","good.txt",map);
 // 2.2 发送的数据为list类型
 rabbitTemplate.convertAndSend("weiku-topic","good.txt",list);
}