robustmq/robustmq

何を解決するか

RobustMQは、異なるプロトコル用に別々のブローカーをデプロイする必要をなくす統合メッセージエンジンを提供します。特に、複数エージェントAIシステムにおける断片化に対処しており、エージェント同士が互いを見つける（ディスカバリ）ことや、可用性の異なる状態間で信頼性の高い非同期メッセージングを行うことが困難な問題を解決します。

動作方法

Rustで構築されたこのシステムは、単一のバイナリと共有ストレージレイヤーを使用します。これにより、あるプロトコル（例：MQTT）で送信されたメッセージを、別のプロトコル（例：Kafka）で受信できます。AIエージェント向けに mq9 プロトコルを導入し、意味的ディスカバリ（機能に基づくエージェント検索）のための組み込みレジストリと、受信エージェントがオンラインになるまでメッセージを保持する永続的なメールボックスを提供。優先度は3段階に対応しています。

対象ユーザー

• AI開発者：複数エージェントシステムを構築しており、エージェントが登録・ディスカバリ・非同期通信を行うための標準化された方法を必要とする人。
• IoTおよびエッジエンジニア：エッジデバイスからクラウドクラスタまで動作する高パフォーマンス・低リソース消費のブローカーを必要とする開発者。
• エンタープライズアーキテクト：MQTT、Kafka、NATS、AMQPなどの複数のメッセージングプロトコルを単一のインフラ層に統合したいチーム。

特徴

• マルチプロトコル統合：MQTT、Kafka、NATS、AMQP、mq9 すべてが同じストレージエンジンを共有するネイティブサポート。
• mq9エージェントインフラ：AIエージェント専用のツール群。意味的ベクトル検索によるディスカバリと、優先度ベースのメールボックスを提供。
• Rustネイティブパフォーマンス：ガベージコレクションなし、予測可能なメモリ使用量。エッジからクラウドまで展開可能。
• 外部依存なし：Raftコンセンサスが内蔵された単一バイナリ。運用を簡素化。
• 柔軟なストレージ：メモリ、RocksDB、ファイルバックエンドをサポート。自動的に冷データをS3にティアリング。