Apache RocketMQ 分布式消息引擎

Apache RocketMQ 是一款由阿里巴巴于2012年开源的分布式消息和流处理平台，最初为应对双十一购物节海量交易流量而设计，单日可处理万亿级消息吞吐。2017年成为Apache顶级项目后，逐步演进为支持AI原生场景的新一代消息引擎，内置模型上下文协议连接器，可直接与大语言模型智能体对接编排。其核心架构采用NameServer路由集群与Broker存储集群分离设计，消除了单点故障风险，支持水平横向扩展。在消息模型方面，支持点对点队列、发布订阅主题、定时延迟投递、两阶段提交事务消息以及跨分区顺序消息等多种模式。消费者可采用并发或顺序消费策略，具备至少一次投递保证，自动重试机制配合死信队列有效处理异常消息。流处理能力方面，提供与Kafka语义兼容的事件流API、基于SQL92的消息过滤规则，以及幂等生产者实现的精确一次投递保障。最新版本新增了多模态消息路由功能、面向AI智能体编排的协议连接器，以及使用C++和Rust重写的跨语言高性能客户端库。平台配套RocketMQ Dashboard监控控制台，支持集群状态监控、主题管理与消息轨迹追踪。消息压缩采用LZ4算法，批量发送提升吞吐，支持消息时间线查询实现消息回溯。部署形态灵活，从单节点开发环境到全球跨地域复制的分布式集群均可覆盖。