消息队列#
知识脉络#
消息队列
├── 通用概念
│ ├── 为什么用MQ（解耦/异步/削峰）
│ ├── MQ选型（Kafka vs RocketMQ vs RabbitMQ）
│ └── 消息模型（点对点/发布订阅）
├── Kafka
│ ├── 架构（Broker/Topic/Partition/Replica/Controller）
│ ├── 高性能原因（顺序写/零拷贝/批量/压缩）
│ ├── 存储与日志结构（Segment/稀疏索引）
│ ├── 日志清理与 Compaction（delete/compact）
│ ├── 消费者组与 Rebalance
│ ├── ISR 机制
│ ├── Exactly-Once 语义
│ └── 运维与积压排障
├── RocketMQ
│ ├── 架构（NameServer/Broker）
│ ├── 事务消息
│ ├── 延迟消息
│ └── 消息过滤（Tag/SQL92）
├── 可靠性
│ ├── 消息丢失（生产端/Broker/消费端）
│ ├── 消息重复与幂等
│ └── 消息顺序性
└── 实战问题
├── 消息积压处理
├── 死信队列
└── 消息回溯
plaintext知识点清单#
口诀速记#
- MQ三大用途: “解异削（解耦/异步/削峰）”
- 消息丢失三环节: “生产acks=all+重试 / Broker多副本(min.insync≥2) / 消费手动ACK+幂等”
- Kafka快: “顺序写+零拷贝+分区并行+批量+压缩”
- 幂等三板斧: “唯一ID+去重表+业务状态机”
跨域关联#