2. 消息队列基础回顾：主流MQ对比、消息模型与生产消费模式
在深入消息队列任务契约测试之前，有必要先统一对消息队列基础概念的理解。本章从三个维度展开：主流MQ的选型对比、核心消息模型以及生产消费模式。这些知识是后续版本协商机制与契约测试的基石。
2.1 主流消息队列对比：Kafka / RabbitMQ / RocketMQ
当前业界最主流的消息队列中间件为 Apache Kafka、RabbitMQ 和 Apache RocketMQ。三者设计哲学不同，适用场景也有明显差异。下表从关键维度进行横向对比：
| 对比维度 | Kafka | RabbitMQ | RocketMQ |
|---|---|---|---|
| 设计定位 | 分布式流处理平台 | 通用消息代理 | 分布式消息中间件 |
| 消息模型 | 分区日志模型（Topic + Partition） | 交换机/队列模型（Exchange + Queue） | 主题队列模型（Topic + MessageQueue） |
| 消费模式 | 拉模式（Pull）为主 | 推模式（Push）为主，支持拉模式 | 推拉结合（长轮询） |
| 消息顺序 | 分区内严格有序 | 单队列有序 | 分区内严格有序 |
| 消息可靠性 | ACK + 副本机制，高吞吐 | ACK + 镜像队列，高可靠 | ACK + 同步/异步刷盘，高可靠 |
| 吞吐量 | 极高（百万级/秒） | 中等（万级/秒） | 高（十万级/秒） |
| 延迟 | 毫秒级（批量处理） | 微秒级 | 毫秒级 |
| 协议支持 | 自定义二进制协议 | AMQP 0-9-1、STOMP、MQTT | 自定义二进制协议 |
| 典型场景 | 日志收集、流计算、大数据管道 | 微服务解耦、任务队列、RPC | 交易消息、订单系统、IoT |
选型建议： 如果团队追求极致的吞吐量和流式处理能力，Kafka 是首选；如果业务需要灵活的路由策略和低延迟，RabbitMQ 更合适；如果业务场景在金融级可靠性、事务消息和顺序消息上有强需求，RocketMQ 是平衡之选。
2.2 消息模型：从生产者到消费者的路径
消息模型定义了消息从产生到消费的完整路径。虽然不同MQ的实现细节不同，但核心抽象是一致的：生产者将消息发送到服务端，服务端按规则存储并路由，消费者从服务端拉取或接收消息。
下图展示了三种主流MQ的消息模型对比：
关键理解： 消息模型的核心在于“消息的存储与路由方式”。Kafka 的日志模型天然适合顺序消费和回溯；RabbitMQ 的交换机模型提供了最灵活的路由能力；RocketMQ 的队列模型在顺序性和扩展性之间取得了良好平衡。
2.3 生产消费模式：推、拉与长轮询
生产消费模式决定了消费者如何获取消息。三种主流模式各有优劣：
- 推模式（Push）： 服务端主动将消息推送给消费者。优点是实时性高，缺点是消费者可能被压垮（背压问题）。RabbitMQ 的默认模式即为此。
- 拉模式（Pull）： 消费者主动向服务端拉取消息。优点是消费者可以控制消费速率，缺点是可能引入轮询延迟。Kafka 的消费者基于此模式。
- 长轮询（Long Polling）： 消费者发起拉取请求，服务端在有消息时立即返回，否则保持连接等待一段时间。RocketMQ 采用此方式，兼顾了实时性和可控性。
下图展示了三种模式的工作流程对比：
注意： 在消息队列任务契约测试中，生产消费模式直接影响契约版本协商的交互方式。例如，在拉模式下，消费者可以在拉取请求中携带期望的契约版本号，服务端据此决定返回哪个版本的消息格式。推模式则需要在连接建立阶段完成版本协商。
2.4 消息队列核心概念速查
为方便后续章节引用，下表汇总了消息队列中的核心概念及其在三种MQ中的对应关系：
| 核心概念 | Kafka | RabbitMQ | RocketMQ |
|---|---|---|---|
| 消息 | Record | Message | Message |
| 主题 | Topic | Exchange + Routing Key | Topic |
| 队列/分区 | Partition | Queue | MessageQueue |
| 消费者组 | Consumer Group | Consumer (无组概念，通过Queue绑定) | Consumer Group |
| 偏移量 | Offset | Delivery Tag | Queue Offset |
| 消息确认 | Commit / ACK | ACK / NACK | ACK |