消息队列选型对比

为什么需要消息队列

消息队列（Message Queue）是分布式系统中重要的中间件，主要解决以下问题：

• 解耦：生产者和消费者独立演进
• 削峰填谷：缓冲突发流量，保护后端系统
• 异步处理：将非核心操作异步化，提升响应速度
• 可靠通信：通过持久化和确认机制确保消息不丢失

主流消息队列对比

特性	RabbitMQ	Apache Kafka	RocketMQ	Apache Pulsar
开发语言	Erlang	Scala/Java	Java	Java
协议	AMQP 0-9-1	自定义协议	自定义协议	自定义协议
消息模型	Exchange + Queue	Topic + Partition	Topic + Queue	Topic + Partition
顺序消息	单队列有序	分区内有序	分区内有序	分区内有序
消息回溯	不支持	支持（基于 offset）	支持（基于时间）	支持（基于时间）
吞吐量	万级/秒	百万级/秒	十万级/秒	百万级/秒
延迟	微秒级	毫秒级	毫秒级	毫秒级
运维复杂度	低	中	中	高

选型建议

选择 RabbitMQ 的场景

• 需要灵活的路由策略（Direct、Topic、Fanout、Headers）
• 对延迟敏感，要求微秒级响应
• 运维团队较小，需要成熟稳定的方案
• 典型场景：任务队列、RPC 调用、事件通知

选择 Kafka 的场景

• 高吞吐量需求（日志收集、metrics 数据）
• 消息顺序性要求高
• 需要消息回溯（replay）能力
• 典型场景：日志聚合、流式处理、事件溯源

选择 RocketMQ 的场景

• 需要事务消息支持
• 需要精准的消息投递语义
• Java 技术栈为主
• 典型场景：订单交易、金融级消息

核心概念

RabbitMQ 架构

Producer → Exchange → Binding → Queue → Consumer
                ↓
          Dead Letter Exchange

Kafka 架构

Producer → Topic (Partition 0, 1, 2...) → Consumer Group → Consumer
                              ↓
                        ISR (In-Sync Replicas)

关键指标

选型时还应考虑：

• 持久化：消息存储在磁盘还是内存？故障恢复策略？
• 高可用：集群模式、Leader 选举、数据复制机制
• 监控：是否有完善的监控指标和管理界面
• 生态：与周边系统（Spark、Flink、Spring）的集成度