RabbitMQ 入门(三)SpringAMQP

一、Spring AMQP 简介

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

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

SpringAMQP提供了三个功能：

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

        AMQP，即Advanced Message Queuing Protocol，是用于在应用程序之间传递业务消息的开放标准，该协议与语言和平台无关，更符合微服务中独立性的要求。

        Spring AMQP 是基于AMQP协议定义的一套API规范，提供了模版来发送和接受消息。包含两部分，其中Spring-amqp是基础抽象，spring-rabbit是底层的默认实现。

二、使用Spring AMQP实现基础消息队列功能

基础消息队列模式的模型图：

基础的消息队列模型包括三个角色：

- publisher：消息发布者，将消息发送到队列queue
- queue：消息队列，负责接受并缓存消息
- consumer：订阅队列，处理队列中的消息

使用Spring AMQP实现基础消息队列功能

流程如下：
1.在父工程中引入spring-amqp的依赖
2.在publisher 服务中利用RabbitTemplate发送消息到 simple.queue 这个队列
3.在consumer服务中编写消费逻辑,绑定 simple.queue 这个队列

步骤一：在父工程中引入依赖

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

步骤二：在publisher中编写测试方法，向 simple.queue发送消息

1).在publisher服务 中编写application.yml，添加mq连接信息：

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

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

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)
@SpringBootTest
public class SpringAmqpTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSimpleQueue() {// 队列名称String queueName = "simple.queue";// 消息String message = "hello, spring amqp!";// 发送消息rabbitTemplate.convertAndSend(queueName, message);}
}

步骤三：在consumer服务中编写消费逻辑,绑定 simple.queue 这个队列

 1.在consumer服务中编写 application.yml,添加mq连接信息;

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

 2.在consumer服务中新建一个类,编写消费逻辑

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

步骤四：运行springboot程序，测试发送接收消息。成功