robustmq/robustmq

解决的问题

RobustMQ 提供统一的消息引擎，消除了为不同协议部署多个独立代理的需要。它特别解决了多智能体 AI 系统中的碎片化问题，即智能体常常难以相互发现（发现）以及在不同可用性状态下可靠地进行异步通信。

工作原理

该系统使用 Rust 编写，采用单一二进制文件和共享存储层。这使得通过一种协议（例如 MQTT）写入的消息，可以通过另一种协议（例如 Kafka）进行消费。针对 AI 智能体，引入了 mq9 协议，提供内置的语义发现注册表（按能力查找智能体）和持久化邮箱，可将消息存储至接收智能体上线为止，支持三级优先级。

适用人群

• AI 开发者：构建多智能体系统，需要一种标准化方式让智能体注册、发现并异步通信。
• IoT 和边缘工程师：需要高性能、低资源占用的代理，适用于从边缘设备到云集群的场景。
• 企业架构师：希望将多种消息协议（MQTT、Kafka、NATS、AMQP）整合到单一基础设施层的团队。

核心亮点

• 多协议统一：原生支持 MQTT、Kafka、NATS、AMQP 和 mq9，共享同一存储引擎。
• mq9 智能体基础设施：专为 AI 智能体设计的工具，包括基于语义向量搜索的发现机制和基于优先级的邮箱。
• Rust 原生性能：无垃圾回收，内存占用可预测，适用于边缘到云端的部署。
• 零外部依赖：单个二进制文件，内置 Raft 共识机制，简化运维。
• 灵活存储：支持内存、RocksDB 和文件后端，并支持自动将冷数据分层至 S3。