Spring Cloud消息队列-rabbitmq的简单使用_springcloud 接入rabbitmq 监听多个队列

一、消息队列

如果想了解什么是消息队列，可以观看这个帖子。 SpringCloud-快速了解消息队列：

二、rabbitmq在Docker下的安装

如果你是零基础接触linux和docker，建议先读完一下两个帖子：
Linux目录结构及基本指令使用.
Docker的概念及基本指令学习.

1. 首先在虚拟机或服务器上启动docker

docker run -d --hostname cslcp-rabbit  --name cslcp-rabbit -p 15672:15672 -p 11223:5672  rabbitmq:3-management
1

2. 其次输入网址，进入到客户端中
   
3. 了解界面结构
   
4. 添加用户
   
   
   rabbitmq部署完毕！

三、rabbitmq在Spring Cloud 下的使用

在消息产生侧引入依赖：

<!-- 消息队列 spring boot整合方案 -->
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-amqp</artifactId>
	<version>2.0.4.RELEASE</version>
</dependency>
1
2
3
4
5
6

在消息产生侧yml中引入配置：

在config类中注册一个队列Bean：（Queue中的名字）

创建一个实现类用于处理发送的消息：

创建一个接口用于发送消息到队列中：

使用Postman调用接口发送数据：

可以发现rabbitmq的数据涨了一条。产生消息成功。

在消费消息侧引入依赖：

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-amqp</artifactId>
	<version>2.0.4.RELEASE</version>
</dependency>
1
2
3
4
5

在消费消息侧yml中添加rabbitmq：

在消费消息侧添加消费类：

启动工程，发现消息会自动消费:

如果你先看他消费的速度，你可以在产生消费时加一个1000000的for循环，消息产生后，观看消息消费侧的控制台，因为不涉及到业务操作，所以说会很快。

制作整理不易，以上内容均为原创（参考了部分官方文档和老师整理的案例）。如要引用请附上本文链接，如有疑问可以在评论区畅所欲言，作者看到会第一时间回复，欢迎交流！