RabbitMQ · 深入教程 · 概念为主
RabbitMQ：智能 broker 的消息模型
基于 RabbitMQ 4.x（4.3，2026-04）。阅读时间约半天（deep-dive）。本教程以概念与机制为主，示例配置/命令用于说明，未在本机逐条运行的会就地标注。读完你会用一条主线看懂 RabbitMQ，并能和 Kafka 做选型。
·适合谁
这份教程假设你具备以下三项。任一项缺失，下面"不适合谁"有更合适的去处。
- 能读懂一段后端服务代码，理解线程、TCP 连接、进程这些基本概念。
- 用过至少一种消息系统或队列——最好是 Kafka。本教程大量以"你已经懂 Kafka"为支点来讲 RabbitMQ 的不同之处。
- 目标是系统理解 RabbitMQ 的模型与机制（为面试、架构评审或选型），而不是只复制一段能跑的代码。
·不适合谁
- 完全没接触过消息队列：先读一篇"为什么需要消息队列"的入门，再回来，否则第 1 章的解耦动机会落空。可看 CloudAMQP: What is message queuing。
- 只想要一段能跑的 Python/Java 收发代码：直接看 官方六个 tutorial 更快；本教程刻意不做代码渐进，重在心智模型。
- 要做 RabbitMQ 集群部署与调优实操：本教程讲清机制与判据，但不是一份运维手册；落地时配合官方 Production Checklist。
·读完之后你能做到什么
读完你能用一条主线——"智能 broker、ack 后删除" 对 "Kafka 不可变日志、offset 可重放"——当场讲清 RabbitMQ 的路由灵活、无重放、单队列吞吐瓶颈为什么是同一个设计决策的三个侧面，并据此做 RabbitMQ/Kafka 选型，而不是背一张特性对比表。具体而言：
- 画出消息从 producer 经 exchange、binding 到 queue、再到 consumer 并在 ack 后删除的完整路径。
- 区分四种 exchange 的路由规则，为给定订阅需求写出正确的 binding key。
- 说清 publisher confirms 与 consumer ack 各防住哪一类丢失，以及 durable / persistent / quorum 三者的区别——尤其"classic 队列确认后仍可能丢"。
- 解释 quorum 队列用 Raft 如何取代已移除的镜像队列，以及为什么单个队列是吞吐天花板。
- 在给定场景下判断该用 RabbitMQ 还是 Kafka、该用哪种 queue、哪种 exchange，并讲出依据。
一句话本质
RabbitMQ 是"智能 broker / 笨消费者"：路由、投递追踪、ack 后删除都发生在 broker 内部，消息一旦被 ack 就消失。这与 Kafka"笨 broker / 智能消费者 + 不可变日志 + 消费者自己记 offset"正好相反。抓住这一点，后面所有特性都是它的推论。
稳定核心：AMQP 0-9-1 模型（exchange/queue/binding）、publisher confirms、consumer ack、prefetch——十余年稳定，放心学。
近期变动：4.0（2024-09）把 AMQP 1.0 升为一等核心协议、默认消息上限从 128 降到 16 MiB；4.2（2025-10）Khepri 成为新节点默认元数据存储；4.3（2026-04）Khepri 成唯一存储、Mnesia 移除。quorum 队列现为默认队列类型。
已被取代（别再学旧做法）：classic mirrored queues（镜像队列，ha-mode）在 4.0 移除 → 用 quorum 队列；Mnesia → Khepri；AMQP 事务 tx → publisher confirms。看到这些旧配置，基本能判定材料过时。
这份教程在很多地方会故意让你慢下来——预测题、折叠的答案、"自己先画一张图"。原因是：读得顺，不等于学会了。三种感觉最会骗人，遇到时停一下：
「我读得很顺」——顺往往只是眼熟，不是掌握。合上页面能复述吗？
「我做题很快」——快往往是题型见过，换个场景还快吗？
「我没卡壳」——没卡壳可能是没碰到真正的难点。把答案盖住自己讲一遍试试。
·概念地图
·学习路径建议
顶部面包屑就是线性路径（00→05，每章高亮当前位置）。按目标挑一条走法：
| 你的目标 | 建议路线 |
|---|---|
| 只想建立心智模型 | 01 模型 → 02 可靠投递 →（03 跳读）→ 04 对标，重在理解"为什么" |
| 面试 / 架构评审 | 01 → 02 → 03 → 04 → 05 全程，重点啃 03 的 Raft/流控 与 04 的选型判据 |
| 已有 Kafka 基础、只想搞清差异 | 先看 01 §1.4 生命周期 → 直奔 04 对标 → 回补 02 可靠性与 03 机制 |
·目录
- 01模型与路由Connection/Channel、exchange/queue/binding、四种 exchange、消息生命周期（ack 后删除）
- 02可靠投递publisher confirms、consumer ack 与 prefetch、durable≠persistent≠safe、dead-letter 与重试上限、内存/磁盘告警
- 03内部机制AMQP 帧、每队列一个 Erlang 进程、credit 流控、quorum 队列与 Raft、Khepri 取代 Mnesia
- 04对标选型架构对照、push/pull、顺序与重放、吞吐与延迟（真实数字）、RabbitMQ/Kafka/Streams 决策树
- 05自测与辨析三层梯度题库、跨章选型场景题、"自己画一张图"——把答案盖住才有意义
·学完之后
- AMQP 1.0 与多协议：4.x 把 AMQP 1.0 升为核心协议，MQTT 5.0 原生支持——它在 schema 上加的是"RabbitMQ 不只是 AMQP 0-9-1"。
- RabbitMQ Streams 深入：super-streams、offset 跟踪、服务端过滤——补上"重放/事件流"这一侧，和 Kafka 正面对比。
- 可观测性：Prometheus + Grafana 监控 quorum 队列、内存/磁盘告警、unacked 堆积——把第 2、3 章的故障信号变成可观测指标。
- 客户端实战：Spring AMQP / Java client 的连接与 channel 池、消费者并发模型——把第 1 章的 channel 规则落到代码层。