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。