Skip to content
目标 Apache 顶级项目 · Rust 构建 · 多协议原生支持
RobustMQmq9
AI 时代的数据通信基础设施
一个二进制，一个 Broker，无外部依赖。原生支持 MQTT、Kafka、NATS、AMQP，统一存储层，一份数据，任意协议消费分发。
mq9为 AI Agent 设计的通信层 · Agent 邮箱，发出去对方上线自然收到→里程碑演示
一份数据，四协议同时消费
MQTT 写入，MQTT / Kafka / NATS / AMQP 四端原生消费，底层一份数据，零桥接，零复制
核心场景
六大场景，一个二进制
不是协议孤岛的拼接，是从架构底层统一解决
AI Agent 通信
原生 Agent 基础设施
- $mq9.AI.API.* Subject 空间，Agent 注册、发现、调用
- 百万级轻量 Topic，每个 Agent 独立通道
- NATS Queue Group 原生负载均衡，零学习成本
IoT 设备接入
MQTT in / Kafka out
- 设备 MQTT 接入，AI 平台 Kafka 消费同一份数据
- 一套系统替代 MQTT Broker + Kafka 双架构
- 极小内存，支持边缘网关部署
实时流数据管道
Kafka 协议完整兼容
- 标准 Kafka SDK 无缝接入，零迁移成本
- 百万级轻量 Topic，满足大规模数据分区
- 冷数据自动分层到对象存储
边缘到云端同步
统一边缘与云端
- 单二进制极小内存占用，边缘节点零依赖部署
- 断网本地缓存，网络恢复后自动同步云端
- 工厂、零售、车载场景统一数据通路
超低延迟实时分发
NATS 纯内存路由
- 消息不落盘，直接内存路由推送，毫秒到亚毫秒延迟
- 金融行情、游戏状态同步、工业控制、AI 推理分发
- 需持久化时切换 JetStream 模式，统一存储层接管
传统消息分发
AMQP 原生支持
- 完整 AMQP 协议，Exchange / Queue / Binding 原生实现
- 现有 RabbitMQ 应用低成本迁移
- 同时获得多协议互通能力
系统架构
三组件，极简边界
计算、存储、调度完全分离，每层独立扩展，单二进制交付
↔
集群协调
Broker
协议解析 · 消息路由 · 无状态
MQTT · Kafka · NATS · AMQP
↕
数据读写
Storage Engine
Memory · RocksDB · File Segment
ISR · Tiered Storage · S3
角色由配置决定
三个角色单二进制交付
存算彻底分离
核心特性
从内核开始设计
Rust 构建
无 GC，内存稳定可预测，无周期性波动，极小内存占用，从边缘设备到云端集群统一部署
统一存储层
所有协议共享同一存储引擎，数据只写一份，按协议语义消费，无数据复制
多协议原生支持
MQTT 3.1/3.1.1/5.0、Kafka、NATS、AMQP 原生实现，各自保持完整协议语义
边缘到云端
单二进制零依赖，断网缓冲自动同步，从边缘网关到云端集群极简部署
AI Agent 通信
基于 NATS 的 $mq9.AI.API.* 扩展，原生支持 Agent 注册、发现、调用和编排
多模式存储引擎
内存 / RocksDB / 文件三种形态，Topic 级独立配置，冷数据自动分层到 S3
共享订阅
突破"并发度 = Partition 数量"的限制，消费者随时弹性伸缩
原生多租户
所有协议统一的多租户支持，客户端无感知，租户间数据完全隔离，权限独立管理
极简运维
单二进制，零外部依赖，内置 Raft 共识，开箱即用