🔥个人主页：代码不加冰（欢迎来访）
🎬作者简介：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 的访问权限
