消息队列 · 必学内容图 | 祥哥的技术博客

消息队列 · 必学内容图

A. MQ 基础与选型

A1. 为什么需要 MQ：异步、解耦、削峰及引入代价

为什么需要 MQ MQ 在微服务架构中解耦的边界是…

A2. 消息模型：Queue（P2P）vs Pub/Sub

为什么需要 MQ Pulsar 架构深入

A3. 三大/四大 MQ 选型对比：Kafka / RabbitMQ / RocketMQ / Pulsar（吞吐、延迟、可靠性、功能、运维）

消息队列选型对比 MQ 选型与容量规划 RabbitMQ 集群高可用

A4. 容量规划与分区数估算

MQ 选型与容量规划

B. Kafka 原理

B1. 核心概念：Topic / Partition / Replica / Segment / offset

Kafka 核心概念 Kafka 的可靠性与高性能架构

B2. 生产者原理：累加器、Sender、分区器、acks、重试

生产者与消费者原理 Kafka 高性能核心设计

B3. 消费者原理：poll 模型、位移提交、Rebalance（JoinGroup/SyncGroup）

生产者与消费者原理 Kafka 消费组重平衡机制与优…

B4. 分区分配策略：Range / Sticky / CooperativeSticky

Kafka 分区分配策略

B5. 存储原理：分段日志、稀疏索引、页缓存、日志清理（delete/compact）

Kafka 高性能核心设计 Kafka 核心概念 Kafka 日志保留与清理

B6. Controller 与 ZooKeeper / KRaft 元数据管理

Kafka KRaft 模式 Kafka 核心概念

B7. Kafka 高性能：顺序写、零拷贝 sendfile、批处理、压缩

Kafka 高性能核心设计 Kafka 的可靠性与高性能架构

C. Kafka 可靠性与语义

C1. ISR / HW / LEO、acks 机制与 min.insync.replicas

Kafka 消息可靠性 Kafka 的可靠性与高性能架构

C2. 消息丢失全链路场景（生产端/broker/消费端）

Kafka 消息丢失场景与排查不丢、不重、不积压

C3. 幂等生产者与 Exactly-Once 语义（事务、read-process-write）

Kafka Exactly-On…Kafka 事务原理与分布式事务…Kafka 的可靠性与高性能架构

C4. 消息顺序：分区内有序、跨分区方案、乱序事故

Kafka 消息顺序保证生产事故复盘

C5. Rebalance 触发条件、危害与优化

Kafka 消费组重平衡机制与优…生产者与消费者原理

C6. 生产事故排查：发送超时、消费延迟、堆积

Kafka 生产事故不丢、不重、不积压

D. RabbitMQ

D1. AMQP 模型：Exchange / Binding / Queue，四种 Exchange 类型

RabbitMQ 基础架构 RabbitMQ 入门

D2. 可靠投递：Confirm、Return、手动 ack、prefetch/QoS

RabbitMQ 消息可靠投递 RabbitMQ 入门

D3. 集群与高可用：普通集群 / 镜像队列 / Quorum Queue

RabbitMQ 消息可靠投递 RabbitMQ 集群高可用 RocketMQ 高可用演进

D4. TTL、DLX 死信与延迟队列实现

延迟消息实现方案对比 RabbitMQ 入门

D5. 消息积压与流控（memory/disk alarm）

消息堆积治理

E. RocketMQ

E1. 架构：NameServer / Broker 主从 / Producer / Consumer

RocketMQ 架构设计 RocketMQ 详解

E2. 存储：CommitLog / ConsumeQueue / IndexFile、同步刷盘 vs 异步刷盘、同步复制 vs 异步复制

RocketMQ 架构设计 RocketMQ 详解

E3. 事务消息：半消息、本地事务、回查

RocketMQ 事务消息机制与…RocketMQ 详解

E4. 顺序消息：MessageQueueSelector、队列锁

RocketMQ 架构设计生产事故复盘

E5. 延时消息：18 固定级别 vs 5.x 任意延时

RocketMQ 详解延迟消息实现方案对比

E6. 消息过滤：Tag 与 SQL92

RocketMQ 架构设计

E7. 高可用演进：主从切换、DLedger / 新版 Controller

RocketMQ 详解 RabbitMQ 集群高可用 RocketMQ 高可用演进

E8. 消息轨迹、重试与死信队列、消费幂等

死信队列与消息回放 RocketMQ 详解不丢、不重、不积压

F. 通用问题与运维

F1. 消息可靠性三板斧：不丢、不重（幂等设计）

不丢、不重、不积压死信队列与消息回放

F2. 消息堆积治理（三 MQ 各自手段）

消息堆积治理

F3. 延迟消息方案对比（TTL+DLX / RocketMQ / Redis ZSet）

延迟消息实现方案对比 RocketMQ 高可用演进

F4. 死信队列与消息回放

死信队列与消息回放

F5. 削峰填谷与消费速率控制、背压

MQ 削峰填谷与流量控制

F6. 跨集群复制与容灾：MM2、双活、防环、offset 同步

消息中间件跨集群复制方案与容灾设…

F7. 消息顺序的通用保证手段

Kafka 消息顺序保证生产事故复盘

F8. MQ 解耦边界与过度使用

MQ 在微服务架构中解耦的边界是…

F9. 流处理：Kafka Streams（及与 Flink 定位差异）

Kafka Streams 流处…

F10. Pulsar：存算分离、BookKeeper、订阅模式、分层存储

Pulsar 架构深入