📚 课程目录第1章 RabbitMQ基础回顾

1. RabbitMQ 基础回顾：核心概念与消息模型

RabbitMQ 是目前最流行的开源消息中间件之一，基于 AMQP 0-9-1 协议实现。在深入读写分离架构之前，必须牢固掌握其核心概念与消息流转模型。本节将系统梳理 Exchange、Queue、Binding、Routing Key 四大核心要素，并解析 AMQP 协议的基本工作流程。

1.1 核心概念速览

概念	角色	关键说明
Producer	消息生产者	将消息发送到 Exchange，不直接发送到 Queue
Exchange	消息路由器	接收生产者消息，根据 Binding 规则将消息路由到 Queue
Queue	消息存储容器	消费者从 Queue 拉取或订阅消息；消息持久化依赖 Queue 配置
Binding	绑定关系	将 Exchange 与 Queue 关联，并指定 Routing Key 匹配规则
Routing Key	路由键	消息携带的标签，Exchange 根据 Routing Key 与 Binding 规则决定投递目标
Consumer	消息消费者	从 Queue 获取消息进行处理，支持 Push 和 Pull 两种模式

关键认知： 生产者从不直接与 Queue 交互，所有消息必须经过 Exchange 路由。这是 RabbitMQ 灵活性的核心设计，也是实现读写分离架构的基础前提。

1.2 Exchange 的四种类型

Exchange 是消息路由的大脑，RabbitMQ 内置四种类型，每种类型决定了 Routing Key 的匹配策略：

Direct Exchange：精确匹配。消息的 Routing Key 必须与 Binding Key 完全一致，才路由到对应 Queue。
Topic Exchange：模式匹配。Routing Key 使用点号分隔的单词，支持 *（匹配一个单词）和 #（匹配零个或多个单词）通配符。
Fanout Exchange：广播模式。忽略 Routing Key，将消息复制发送到所有绑定的 Queue。
Headers Exchange：头部匹配。不依赖 Routing Key，根据消息头（Headers）的键值对进行匹配，性能较低，实际使用较少。

  读写分离选型建议： 在读写分离架构中，Direct 和 Topic 是最常用的 Exchange 类型。Direct 适合精确路由（如写操作发往主库队列），Topic 适合灵活分发（如按业务模块区分读写流量）。

1.3 AMQP 协议消息流转模型

AMQP（Advanced Message Queuing Protocol）定义了消息从生产者到消费者的完整链路。下图展示了 RabbitMQ 中一次标准消息投递的完整流程：

1.4 消息模型与 AMQP 协议核心机制

AMQP 协议将消息系统分为三层模型，RabbitMQ 完整实现了这一规范：

模型层	组件	职责
交换层	Exchange + Binding	定义消息路由规则，决定消息去向
队列层	Queue	存储消息，保证消息不丢失，支持持久化
传输层	Channel + Connection	管理客户端与 Broker 之间的网络连接与多路复用

常见误区： 很多初学者认为消息直接发送到 Queue。实际上，RabbitMQ 中 没有 Binding 的 Exchange 无法路由任何消息，未匹配的消息会被丢弃（除非设置 Alternate Exchange）。在读写分离架构中，必须为读写流量分别建立清晰的 Binding 链路。

1.5 关键协议特性

Connection 与 Channel：一个 TCP 连接可创建多个 Channel，Channel 是实际执行 AMQP 命令的轻量级会话。读写分离架构中，建议为读写操作分配独立的 Channel。
消息确认（ACK）：Consumer 处理完消息后必须发送 ACK，否则消息会重新入队。这是保证消息不丢失的核心机制。
持久化：Exchange、Queue 和消息均可设置持久化（durable: true），确保 Broker 重启后数据不丢失。
Prefetch Count：控制 Consumer 未确认消息的最大数量，影响消费吞吐量与负载均衡。

  架构启示： 理解 AMQP 协议的分层模型，有助于在读写分离场景中合理规划 Exchange 类型、Binding 粒度以及 Channel 隔离策略。例如，写操作使用 Direct Exchange 精确路由到主库队列，读操作使用 Topic Exchange 按业务维度分发到不同消费者组。