消息队列是分布式系统中解耦和异步处理的核心组件，它为系统提供了可靠的消息传递机制。
本文介绍了消息队列的核心概念和使用场景，帮助你构建松耦合的分布式系统。
Kafka Topic 被划分为多个 Partition（分区），每个 Partition 是一个有序的、不可变的消息序列。
Topic: order-events (3 分区)
Partition 0: [msg0] [msg3] [msg6] [msg9] ...
Partition 1: [msg1] [msg4] [msg7] ...
Partition 2: [msg2] [msg5] [msg8] ...
关键特性：
- 每个分区内部严格有序
- 不同分区之间无序
- 消息写入分区后不可修改
- 每个分区有唯一的 Leader消息队列是分布式系统中解耦和异步处理的核心组件，它为系统提供了可靠的消息传递机制。
本文介绍了消息队列的核心概念和使用场景，帮助你构建松耦合的分布式系统。
| 维度 | RocketMQ | Kafka | 金融选型考量 |
|---|---|---|---|
| 事务消息 | 原生支持 | 0.11+支持但复杂 | ★★★ RocketMQ 胜 |
| 顺序消息 | 全局+分区顺序 | 仅分区内顺序 | ★★ RocketMQ 胜 |
| 延迟消息 | 18个内置级别 | 不原生支持 | ★★ RocketMQ 胜 |
| 消息回溯 | 按时间秒级回溯 | 支持但运维复杂 | ★ RocketMQ 胜 |
| 堆积能力 | 亿级消息堆积 | 依赖磁盘容量 | 持平 |
| 社区背景 | 阿里/蚂蚁金融场景 | 大数据/日志 | ★ RocketMQ 更匹配 |
消息队列是分布式系统中解耦和异步处理的核心组件，它为系统提供了可靠的消息传递机制。
本文介绍了消息队列的核心概念和使用场景，帮助你构建松耦合的分布式系统。
| 特性 | Kafka | RocketMQ | RabbitMQ | Pulsar |
|---|---|---|---|---|
| 开发语言 | Java/Scala | Java | Erlang | Java |
| 所属 | Apache | Apache(阿里) | VMware | Apache |
| 协议 | 自有协议 | 自有协议 | AMQP 0-9-1 | 自有协议 |
| 吞吐量 | ★★★★★ | ★★★★☆ | ★★★☆☆ | ★★★★★ |
| 低延迟 | ★★★☆☆ | ★★★★☆ | ★★★★★ | ★★★★☆ |
| 消息持久化 | ★★★★★ | ★★★★★ | ★★★☆☆ | ★★★★★ |
| 事务消息 | ★★★★☆ | ★★★★★ | ★★★★☆ | ★★★★★ |
| 顺序消息 | ★★★☆☆ | ★★★★★ | ★★★☆☆ | ★★★★☆ |
| 延迟消息 | ☆ | ★★★★★ | ★★★☆☆ | ★★★★☆ |
| 消息回溯 | ★★★★★ | ★★★★★ | ☆ | ★★★★★ |
| 运维复杂度 | ★★★☆☆ | ★★★☆☆ | ★★☆☆☆ | ★★★★☆ |