SpringAMQP的队列模型与使用

淡淡的烟草味﹌ 2024-04-03 13:24 46阅读 0赞

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

SpringAmqp的官方地址：[Spring AMQP][]

![562115a024f1f64da7e064e9d1b34d99.png][]

SpringAMQP提供了三个功能：

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

### 1.Basic Queue 简单队列模型 ###

在父工程mq-demo中引入依赖

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-amqp</artifactId></dependency>

#### 1.1.消息发送 ####

首先配置MQ地址，在publisher服务的application.yml中添加配置：

spring:  rabbitmq:    host: 192.168.150.101 # 主机名    port: 5672 # 端口    virtual-host: / # 虚拟主机    username: itcast # 用户名    password: 123321 # 密码

然后在publisher服务中编写测试类SpringAmqpTest，并利用RabbitTemplate实现消息发送：

package cn.itcast.mq.spring;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class)@SpringBootTestpublic class SpringAmqpTest {    @Autowired    private RabbitTemplate rabbitTemplate;    @Test    public void testSimpleQueue() {        // 队列名称        String queueName = "simple.queue";        // 消息        String message = "hello, spring amqp!";        // 发送消息        rabbitTemplate.convertAndSend(queueName, message);    }}

#### 1.2.消息接收 ####

首先配置MQ地址，在consumer服务的application.yml中添加配置：

spring:  rabbitmq:    host: 192.168.150.101 # 主机名    port: 5672 # 端口    virtual-host: / # 虚拟主机    username: itcast # 用户名    password: 123321 # 密码

然后在consumer服务的`cn.itcast.mq.listener`包中新建一个类SpringRabbitListener，代码如下：

package cn.itcast.mq.listener;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;@Componentpublic class SpringRabbitListener {    @RabbitListener(queues = "simple.queue")    public void listenSimpleQueueMessage(String msg) throws InterruptedException {        System.out.println("spring 消费者接收到消息：【" + msg + "】");    }}

#### 1.3.测试 ####

启动consumer服务，然后在publisher服务中运行测试代码，发送MQ消息

### 2.WorkQueue ###

Work queues，也被称为（Task queues），任务模型。简单来说就是**让多个消费者绑定到一个队列，共同消费队列中的消息**。

![739a5e199397344bf3beaadd9068d5c3.png][]

当消息处理比较耗时的时候，可能生产消息的速度会远远大于消息的消费速度。长此以往，消息就会堆积越来越多，无法及时处理。

此时就可以使用work 模型，多个消费者共同处理消息处理，速度就能大大提高了。

#### 2.1.消息发送 ####

这次我们循环发送，模拟大量消息堆积现象。

在publisher服务中的SpringAmqpTest类中添加一个测

[Spring AMQP]: https://spring.io/projects/spring-amqp
[562115a024f1f64da7e064e9d1b34d99.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/73a96aa7a4fb40c494d601a5e2f89e9d.png
[739a5e199397344bf3beaadd9068d5c3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/e71d6cbd1fb6425397dbce70b0f50a1b.png