【从0到1学RabbitMQ】十分钟上手 RabbitMQ：Docker 部署 + Spring Boot 自动化配置全攻略-平芜编程栈

十分钟上手 RabbitMQ：Docker 部署 + Spring Boot 自动化配置全攻略

喜欢还是喜欢，但可惜就是可惜。

文章目录

十分钟上手 RabbitMQ：Docker 部署 + Spring Boot 自动化配置全攻略
前言
- 场景复现：糟糕的串行设计
- 救星登场：异步解耦
一、消息队列的核心作用
二、Docker极速安装RabbitMQ
- 1.确保已经安装了Docker，可以查询一下别的博客，十分快捷。
- 2.推荐的 Docker 启动命令：
三、核心实操部分（Spring Boot）
- 1. 极速整合 (Dependency)
- 2. 最简配置 (Configuration)
- 3. 生产者：一行代码发送 (Producer)
- 4. 消费者：一个注解监听 (Consumer)
- - 它的默认行为是什么？
总结

前言

场景复现：糟糕的串行设计

故事背景：假设你正在做一个电商系统的“用户注册”功能。产品经理提了三个要求：
1. 用户填表单，存入数据库。
2. 发一条欢迎短信。
3. 发一封激活邮件。
4. 送 100 积分。
传统做法（串行/同步）：代码逻辑是：Save User->Send SMS->Send Email->Add Points
- 算一笔账（痛点）：
  - 存库：50ms
  - 发短信（调三方接口）：100ms
  - 发邮件（网络延迟）：100ms
  - 送积分：50ms
  - 用户等待总时长：300ms。
- 致命伤：如果“发邮件”的服务挂了，或者网络超时，整个注册请求就报错回滚了。用户明明注册了，却提示失败，体验极差。

救星登场：异步解耦

引入 MQ 后：代码逻辑变为：Save User->Send Message to MQ->Return Success。
- 再算一笔账（爽点）：
  - 存库：50ms
  - 发消息给 MQ（极快）：5ms
  - 用户等待总时长：55ms（性能提升 5-6 倍）。
- 至于发短信、发邮件，由后台的消费者慢慢处理，用户根本感知不到。即使邮件服务挂了，消息还在 MQ 里，修好服务后再消费即可，注册功能不受影响。

一、消息队列的核心作用

异步 (Asynchronous)
- 解释：就像你去餐厅点餐。同步是厨师没做完你不能走，必须站在窗口等；异步是你点完单，拿个号牌找地方坐下玩手机，饭好了自然会叫你。
- 价值：提升系统吞吐量和响应速度。
解耦 (Decoupling)
- 解释：上面的例子中，注册服务（A）不再依赖邮件服务（B）。A 只需要把信扔进邮筒（MQ），至于 B 什么时候拿、怎么拿、甚至 B 换成了 C，A 都不用关心。
- 价值：系统之间不再“强绑定”，降低维护成本。
削峰 (Peak Shaving)
- 解释：这是高并发系统的保命符。
- 比喻：双 11 零点，几亿请求涌入。如果直接打到数据库，数据库瞬间崩溃。MQ 就像一个大水库，先把洪水蓄起来，然后按照数据库能承受的速度，慢慢往下游放水。
- 价值：保护脆弱的下游服务不被流量压垮。

二、Docker极速安装RabbitMQ

1.确保已经安装了Docker，可以查询一下别的博客，十分快捷。

2.推荐的 Docker 启动命令：

命令行

docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

命令参数详解：

docker run：启动容器。如果本地没有镜像，Docker 会自动帮我们下载（Pull），实现“免安装”体验。
-d：后台运行（Detached），让容器在后台默默工作，不占用当前终端窗口。
--name rabbitmq：给容器起个名字叫rabbitmq，方便后续管理。
-p 5672:5672：核心端口。Java 代码连接 MQ 用这个端口。
-p 15672:15672：管理后台端口。浏览器访问控制台用这个端口。
rabbitmq:3-management：重点！一定要选带management后缀的镜像，否则无法使用 Web 管理界面。

验证成果：

访问浏览器：http://localhost:15672
默认账号密码：guest/guest

三、核心实操部分（Spring Boot）

这里不使用原生的 amqp-client做介绍了，而是直接使用springboot来是使用rabbitmq，这才是我们真正实用的场景，省略了很多繁琐的步骤。

1. 极速整合 (Dependency)

只需引入一个 starter，Spring 帮你做了 90% 的工作（自动配置连接工厂、连接池等）。

XML

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

2. 最简配置 (Configuration)

只要配个 IP 和密码就能连，其他复杂的参数 Spring Boot 都给了最佳默认值”。

YAML

spring:rabbitmq:host:localhost port:5672username:guest password:guest

3. 生产者：一行代码发送 (Producer)

这里介绍RabbitTemplate。它是 Spring 提供的“神兵利器”。

重点：为了演示最简单的效果，我们先不搞复杂的交换机，直接发给一个具体的队列。

@SpringBootTestpublicclassRabbitMqTest{@AutowiredprivateRabbitTemplaterabbitTemplate;@TestpublicvoidtestSimpleSend(){// 这里的 "simple_queue" 是队列名// 也就是默认交换机，直接根据路由键匹配队列StringqueueName="simple_queue";Stringmessage="Hello, RabbitMQ!";rabbitTemplate.convertAndSend(queueName,message);System.out.println("消息已发送："+message);}}

4. 消费者：一个注解监听 (Consumer)

这里介绍@RabbitListener。

推荐写法（最简，自动声明队列）：

@ComponentpublicclassSimpleConsumer{// 监听 "simple_queue" 队列@RabbitListener(queuesToDeclare=@Queue(name="simple_queue"))publicvoidreceiveMessage(Stringmessage){System.out.println("消费者收到消息: "+message);}}