🔥个人主页：代码不加冰（欢迎来访） 🎬作者简介：java后端学习者 ❄️个人专栏：LeetCode刷题日记 ， 苍穹外卖日记，SSM框架深入，JavaWeb， ✨命运的结局尽可永在，不屈的挑战却不可须臾或缺！
前言：
大家好我是代码不加冰，前面我们刚初步认识了Docker，这里就用Docker来尝试安装一下RabbitMQ，并同时初步认识一下RabbitMQ。
前提：已经装好 Docker Desktop
没装的话先装：
-
Windows/macOS：上 docker.com 下载 Docker Desktop 安装
-
Linux (Ubuntu)：sudo apt install docker.io
安装完后重启电脑，确保 Docker 图标在任务栏/菜单栏跑着。
如果有不清楚的，可以看我前面的文章，有具体步骤：Windows 保姆级 Docker 安装教程（WSL2 版），一篇入门docker
安装 RabbitMQ
打开终端（CMD、PowerShell 或 Terminal），执行：
bash
docker run -d \\
–name rabbitmq \\
-p 5672:5672 \\
-p 15672:15672 \\
-e RABBITMQ_DEFAULT_USER=admin \\
-e RABBITMQ_DEFAULT_PASS=admin123 \\
rabbitmq:management
如果是在 Windows 的 CMD 里，改成一行（去掉 \\）：
cmd
docker run -d –name rabbitmq -p 5672:5672 -p 15672:15672 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin123 rabbitmq:management
等待镜像下载完成（会出现一长串容器ID）。
验证是否成功
浏览器打开：http://localhost:15672
登录：
-
用户名：admin
-
密码：admin123
自己设置即可
看到管理界面 → 成功
日常常用命令
| 停止 | docker stop rabbitmq |
| 启动 | docker start rabbitmq |
| 重启 | docker restart rabbitmq |
| 删掉重来 | docker rm -f rabbitmq |
| 查看日志（出错时用） | docker logs rabbitmq |
RabbitMQ 整体架构
生产者 (Producer) RabbitMQ 服务器 消费者 (Consumer)
│ │ │
│ ┌─────────────────────────────────────┐ │
│ │ Exchange (交换机) │ │
├──────┼──────────→│ │ │
│ │ │ 根据 Routing Key │ │
│ │ │ 路由到 Queue │ │
│ │ └───────────┬─────────────┘ │
│ │ │ │
│ │ ┌───────────▼─────────────┐ │
│ │ │ Queue (队列) │ │
│ │ │ 存储消息 │ │
│ │ └───────────┬─────────────┘ │
│ │ │ │
│ │ ├──────────────────────┤
│ │ │ 消费消息 │
│ │ │ │
│ └─────────────────────────────────────────────────┘
核心概念
| 生产者 | Producer | 发送消息的程序 | 寄快递的人 |
| 消费者 | Consumer | 接收消息的程序 | 收快递的人 |
| 队列 | Queue | 存消息的"信箱" | 快递柜 |
| 交换机 | Exchange | 决定消息去哪儿的"分拣员" | 快递分拣中心 |
| 绑定 | Binding | 交换机和队列之间的"路线图" | 分拣规则 |
管理界面
访问 http://localhost:15672，登录后，我们逐个区域看：
1. Overview（概览）页面 – 登录后默认看到的
┌───────────────────────────────────────────────────────┐
│ RabbitMQ Management │
├─────────────────────────────────────────────────────────┤
│ Overview | Connections | Channels | Exchanges │
│ Queues | Admin │
├─────────────────────────────────────────────────────────┤
│ │
│ Totals: │
│ ┌─────────────┬─────────────┬─────────────┐ │
│ │ Queues: 0 │ Exchanges:7 │ Connections:0│ │
│ │ (你创建的) │ (系统自带的) │ (当前连接) │ │
│ └─────────────┴─────────────┴─────────────┘ │
│ │
│ Node: rabbit@… (你的节点) │
│ │
└─────────────────────────────────────────────────────────┘
重点看：
-
Queues：你创建的队列数量（刚开始是 0）
-
Exchanges：交换机数量（有 7 个默认的）
-
Connections：当前有多少客户端连接
2. Exchanges（交换机）页面 – 点击顶部 "Exchanges"
这里显示所有交换机，重点关注这几个默认的：
| (AMQP default) | direct | 默认交换机，直接用队列名发消息 |
| amq.direct | direct | 直连型，精确匹配 |
| amq.topic | topic | 主题型，模糊匹配 |
| amq.fanout | fanout | 广播型，发给所有队列 |
| amq.headers | headers | 头匹配型（较少用） |
你可以做的实验：
-
点击 amq.fanout → 查看绑定（Bindings）
-
点击 "Add a new exchange" 创建一个自定义交换机
3. Queues（队列）页面 – 点击顶部 "Queues"
刚开始是空的（没有队列）。你需要：
创建一个队列：点击 "Add a new queue"
填写队列名称（比如 my_queue）
其他保持默认，点击 "Add queue"
创建成功后，点击队列名称进入详情页，可以看到：
-
Messages：消息统计（ready/未消费，unacked/已取未确认）
-
Bindings：这个队列绑定了哪些交换机
-
Publish message：可以手动发消息测试
4. Admin（管理）页面 – 点击顶部 "Admin"
这里管理用户、虚拟主机等：
| Users | 管理用户（你创建的 admin 在这里） |
| Virtual Hosts | 虚拟主机（隔离环境，类似数据库的 schema） |
| Policies | 策略（队列TTL、镜像等） |
| Limits | 系统限制（就是刚才你问的 file descriptor 那里） |
一个完整的消息流程
假设你有一个队列叫 my_queue，一个交换机叫 my_exchange：
步骤 1: 创建队列
Queues → Add a new queue → 名称: my_queue
步骤 2: 创建交换机 Exchanges → Add a new exchange → 名称: my_exchange, 类型: direct
步骤 3: 绑定（告诉交换机，消息送到哪个队列） 点击 my_exchange → Bindings → To queue: my_queue, Routing key: my_key → Bind
步骤 4: 发送消息 点击 my_exchange → Publish message → Routing key: my_key, Payload: Hello World → Publish
步骤 5: 查看消息 点击 Queues → my_queue → 可以看到 "Messages ready: 1"
步骤 6: 消费消息 在 my_queue 详情页 → Get messages → Get
消息的生命周期
text
生产者发送消息
│
▼
到达交换机 ──→ 没有匹配队列 → 消息丢失（根据配置可能被返回）
│
│ 有绑定
▼
进入队列
│
├──→ 等待消费者（状态: ready）
│
▼
消费者取走消息（状态: unacked）
│
├──→ 消费者返回 ack（确认）→ 消息删除
│
└──→ 消费者失联/不 ack → 消息重新入队
数据隔离的测试：
我们先添加一个user
可以发现这里是没有可以访问的虚拟主机
然后我们重新登，用我们刚创建的user
在这里我们不能改变消息的
这里能看到队列也是我们设置的权限足够高，超级管理员的权限。
我们创建自己的虚拟主机：
在这里我们可以进行一系列操作，实现数据隔离
-
不同 vhost 之间完全隔离，互不可见
-
同一个名字的队列可以在不同 vhost 中同时存在
-
用户可以被授予不同 vhost 的访问权限
