RabbitMQ设计原理解析 - 编程一生
内容提要
文章介绍RabbitMQ的设计原理：MQ用于流量削峰、异步处理和应用解耦；对比ActiveMQ、Kafka、RocketMQ、RabbitMQ的特点。RabbitMQ基于Erlang，支持AMQP而非JMS，核心为Message Queue、Exchange和Binding，Exchange分fanout、topic、direct、header四类，并通过ack和confirm保证消息可靠传输。
延伸解读
RabbitMQ 与 Kafka 的路由设计差异
文章指出，RabbitMQ 的 Broker 端由 Exchange 和 Queue 组成，Exchange 负责路由，支持 fanout、topic、direct、header 四种类型，灵活性高。而 Kafka 用 topic 逻辑概念简化路由，策略固定：先找 topic，再负载均衡到 Partition。这种差异源于设计目标不同：RabbitMQ 暴露 Channel 等细节给用户，提供更高灵活性；Kafka 则内置实现，类似约定大于配置。
消息可靠传输的机制对比
RabbitMQ 通过 ack 和 confirm 机制保证消息可靠传输：消费者确认后服务端才删除消息，生产者到 Exchange 也有 ack。文章还提到 AMQP 事务机制作为可选方式。相比之下，Kafka 本身不保证仅且仅收到一次，需靠幂等、事务等额外实现。文章认为 IBM Websphere MQ 通过消息序列号保证不丢失、不重传，是更优雅的方案，但因收费研究较少。
选型时需关注的限制与代价
文章对比了各 MQ 的局限：Kafka 单机超过 64 个分区 load 明显飙高，实时性取决于轮询间隔，且可能丢消息，不适合订单业务；RocketMQ 客户端成熟的主要是 Java，未实现 JMS，迁移需改大量代码；RabbitMQ 不支持 JMS，但实现了 AMQP 标准协议，支持多语言。此外，使用 MQ 需额外设施，在开放平台等场景未必优于回调或轮询。
Q&A
RabbitMQ 和 Kafka 在架构上有什么主要区别？
RabbitMQ 的 Broker 端由 Exchange 和 Queue 两部分组成，Exchange 负责路由，支持 fanout、topic、direct、header 四种类型；生产者和消费者通过 Channel 信道连接。Kafka 则用逻辑概念 topic 简化了路由，路由模式固定（先找 topic 再负载均衡到 Partition），且没有 Exchange 和 Channel 的概念，类似于约定大于配置。
RabbitMQ 的 Exchange 有哪几种类型，分别是什么作用？
Exchange 有四种类型：fanout 对每个绑定的消息队列复制一份发送；direct 只发指定的一份，不复制；topic 按通配符匹配发送到多个队列；header 根据指定的过滤条件发送。本质上都是决定消息复制几份、发到哪些 Binding 的队列。
RabbitMQ 如何保证消息可靠传输？
RabbitMQ 通过 AMQP 事务机制和 ack（confirm）两种可选方式保证消息被收到。消息队列和消费者之间有 ack 机制，消息确认安全送达后服务端才删除消息；消息从生产者发送到 Exchange 后也有 ack 机制保证可靠传输。
为什么使用 MQ？主要解决哪些问题？
使用 MQ 主要解决三个问题：流量削峰，像排队一样让系统有条不紊地处理请求；异步处理，A 通过 MQ 给 B 发消息，B 处理完再回消息，同时还能削峰；应用解耦，实现逻辑解耦（请求与结果处理分离）和物理解耦（系统只与 MQ 通信）。
RabbitMQ 为什么不支持 JMS？它支持什么协议？
JMS 是 Java 消息服务，提供消息传递的 Java 标准 API，而 RabbitMQ 是用 Erlang 开发的，对 Java 的支持较弱，因此不支持 JMS。但 RabbitMQ 实现了 AMQP 标准协议，AMQP 统一了数据交换的标准格式，与语言无关。
RabbitMQ 的核心组成是什么？
RabbitMQ 的核心实际上就是 AMQP 的核心：MessageQueue（消息队列）、Exchange（交换机）和 Binding（绑定）。Binding 是 MessageQueue 与 Exchange 之间的连接，Exchange 只能给 Binding 的 MessageQueue 发送消息。
