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로 타이어링.