SpringBoot实现RabbitMQ的简单队列(SpringAMQP 实现简单队列)

文章目录

1. 前言
2. Basic Queue 简单队列模型
- 2.1 父工程导入依赖
- 2.2 消息发送
- - 2.2.1 消息发送方必要的配置
  - 2.2.2 发消息
3. 消息接收
- 3.1 消息接收方必要的配置
- 3.2 接收消息

在这里插入图片描述

1. 前言

SpringAMQP 是基于 RabbitMQ 封装的一套模板，并且还利用 SpringBoot 对其实现了自动装配，使用起来非常方便。

SpringAmqp 的官方地址：https://spring.io/projects/spring-amqp

在这里插入图片描述

说明：

1.Spring AMQP 是对 Spring 基于 AMQP 的消息收发解决方案，它是一个抽象层，不依赖于特定的 AMQP Broker 实现和客户端的抽象，所以可以很方便地替换。比如我们可以使用 spring-rabbit 来实现。

2.spring-rabbit用于与RabbitMQ服务器交互的工具包

3.SpringAMQP提供了三个功能：

自动声明队列、交换机及其绑定关系
基于注解的监听器模式，异步接收消息
封装了RabbitTemplate工具，用于发送和接收消息

2. Basic Queue 简单队列模型

步骤如下：

1.在父工程中引入 spring-amqp 的依赖

2.在 publisher 服务中利用 RabbitTemplate 发送消息到 test2024.simple.queue 这个队列

3.在 consumer 服务中编写消费逻辑，绑定 test2024.simple.queue 这个队列

2.1 父工程导入依赖

<!--AMQP依赖，包含RabbitMQ-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

在这里插入图片描述

2.2 消息发送

2.2.1 消息发送方必要的配置

#  RabbitMQ
rabbitmq:host: **.105.**.**port: 5672username: ****password: ****virtual-host: /

在这里插入图片描述

2.2.2 发消息

@SpringBootTest
public class TestRabbitMQ {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void test01() {//  声明队列名称String queueName = "test2024.simple.queue";String message = "";// 发送消息rabbitTemplate.convertAndSend(queueName, message);}}

注意在执行发送消息前要确保队列先声明到. 所以我们可以先在配置类里声明出队列:

@Configuration
public class RabbitMQConf {//  声明一个 队列 test2024.simple.queue@Beanpublic Queue testSimpleQueue() {return new Queue("test2024.simple.queue");}
}

启动SpringBoot项目后,让该队列先注册进MQ.然后以后执行测试代码都不用再注册了.

当该队列注册进去后,我们执行测试发送消息代码, 执行成功后,看MQ页面:
在这里插入图片描述

如此就完成了消息的发送.

3. 消息接收

3.1 消息接收方必要的配置

spring:rabbitmq:host: ip  # 主机名port: 5672 # 发送消息和接收消息的端口号virtual-host: / # 虚拟主机username: *** # 用户名password: *** # 密码

3.2 接收消息

@Component
@Component
public class SpringRabbitListener {//  监听制定队列，Spring只要接收到该队列的消息就会接收消息@RabbitListener(queues = "test2024.simple.queue")public void rabbitListener(String message){System.out.println("接收到消息:" + message);;}}