消息队列选型指南：Kafka、RabbitMQ、RocketMQ 对比

核心概念对比

特性	Kafka	RabbitMQ	RocketMQ
模型	发布订阅	交换器队列	发布订阅
协议	自定义	AMQP	自定义
语言	Scala/Java	Erlang	Java
吞吐量	极高	中等	高
延迟	毫秒级	微秒级	毫秒级
可靠性	高	极高	极高

Kafka：大数据场景首选

适用场景:

• 日志收集
• 流式数据处理
• 事件溯源
• 高吞吐场景

特点:

# 高吞吐：百万级 TPS
# 持久化：基于磁盘顺序写
# 分区：支持水平扩展
# 消费者组：支持广播和集群消费

架构:

Producer → Topic(Partition) → Consumer Group

RabbitMQ：企业级消息中间件

适用场景:

• 企业应用集成
• 复杂路由需求
• 低延迟场景
• 多协议支持

特点:

# 灵活路由：Exchange + Binding
# 多协议：AMQP、MQTT、STOMP
# 插件生态丰富
# 管理界面友好

路由模式:

• Direct: 精确匹配
• Fanout: 广播
• Topic: 模式匹配
• Headers: 头信息匹配

RocketMQ：阿里开源的金融级 MQ

适用场景:

• 订单交易
• 金融场景
• 消息回溯
• 定时消息

特点:

# 事务消息支持
# 定时/延迟消息
# 消息回溯 (最多 3 天)
# 顺序消息
# 国产中文文档完善

选型建议

需求	推荐
日志/流处理	Kafka
企业集成/复杂路由	RabbitMQ
金融交易/事务消息	RocketMQ
极致低延迟	RabbitMQ
超大规模吞吐	Kafka

总结

没有最好的消息队列，只有最适合的。根据业务场景、团队技术栈和运维能力选择合适的方案才是关键。