Skip to content

README.md

Latest commit

 

History

History
169 lines (121 loc) · 9.3 KB

README.md

File metadata and controls

169 lines (121 loc) · 9.3 KB

RobustMQ Logo

Ask DeepWiki zread Latest Release License GitHub issues GitHub stars Coverage Build Status Rust Version

New generation of cloud-native and AI-native messaging infrastructure

Introduction • Features • Architecture • Quick Start • Build Script • Documentation • Contributing • Community

⚠️ Development Status RobustMQ is currently in early preview phase with active development and testing. A stable release is anticipated in Q3-Q4 2025. Our roadmap includes achieving production readiness and pursuing Apache top-level project status.

🚀 Introduction

RobustMQ is a next-generation, high-performance message queue built in Rust, designed for modern cloud-native and AI systems. It unifies MQTT, Kafka, and AMQP protocols with compute-storage separation architecture, enabling microsecond latency and elastic scaling.

Why RobustMQ?

Traditional message queues face critical challenges in the AI era: protocol fragmentation requiring multiple systems, latency jitter failing real-time AI needs, compute-storage coupling preventing Serverless deployment, and high costs lacking elastic scaling.

RobustMQ provides a unified messaging platform with flexible architecture that supports all scenarios, eliminating the need to maintain multiple message queue systems.

Vision: Become the next-generation cloud-native and AI-native messaging infrastructure, targeting Apache top-level project status.

✨ Features

  • 🚀 High Performance: Rust-powered zero-cost abstractions with microsecond latency and zero GC pauses
  • 🏗️ Compute-Storage Separation: Stateless broker nodes enable second-level elastic scaling and Serverless deployment
  • 🔌 Multi-Protocol Unified: Native support for MQTT 3.1/3.1.1/5.0, Kafka, and AMQP with protocol isolation
  • 💾 Intelligent Storage Tiering: Memory/SSD/Object storage with Topic-level engine selection for cost optimization
  • ☁️ Cloud-Native Ready: Kubernetes-native with auto-scaling, service discovery, and container-friendly deployment
  • 🛠️ Zero-Operations: Single binary deployment with built-in Raft consensus and comprehensive management tools
  • 🔐 Enterprise Security: Multi-auth support, fine-grained permissions, and end-to-end encryption
  • 📊 Full Observability: Prometheus metrics, OpenTelemetry tracing, and Grafana dashboards

🏗️ Architecture

RobustMQ Architecture

Architecture Overview

  • Broker Server: Stateless protocol processing layer supporting MQTT, Kafka, and AMQP with million-level concurrent connections
  • Meta Service: Raft-based distributed metadata management and cluster coordination with automatic failover
  • Journal Server: High-performance persistent storage engine with WAL guarantees and pluggable storage backends
  • Storage Adapter: Unified storage abstraction layer supporting memory, SSD, and object storage with intelligent tiering
  • One Binary Deployment: Single executable with zero external dependencies for simplified operations
  • Protocol Isolation: Dedicated ports per protocol (MQTT: 1883/1885/8083/8085, Kafka: 9092, AMQP: 5672, gRPC: 1228)
  • Compute-Storage Separation: Stateless brokers enable independent scaling and Serverless deployment without data migration
  • Topic-Level Storage: Flexible storage engine selection supporting memory, local, and cloud storage backends

🚀 Quick Start

One-Line Installation

# Install and start RobustMQ
curl -fsSL https://raw.githubusercontent.com/robustmq/robustmq/main/scripts/install.sh | bash
broker-server start

Quick Test

# Test MQTT connection
mqttx pub -h localhost -p 1883 -t "test/topic" -m "Hello RobustMQ!"
mqttx sub -h localhost -p 1883 -t "test/topic"

Web Dashboard

Access http://localhost:8080 for cluster monitoring and management.

Web UI Web UI Cluster

Try Online Demo

📚 For detailed installation and usage guides, see our Documentation

🔧 Development

# Clone and build
git clone https://github.com/robustmq/robustmq.git
cd robustmq
cargo run --package cmd --bin broker-server

# Build packages
make build              # Basic build
make build-full         # With frontend

📚 For detailed build options, see our Build Guide

📚 Documentation

🤝 Contributing

We welcome contributions! Check out our Contribution Guide and Good First Issues.

🌐 Community

🇨🇳 Chinese Community

  • 微信群: Join our WeChat group for Chinese-speaking users

    WeChat Group QR Code

  • 微信公众号: If the group QR code has expired, welcome to follow our official WeChat account!

    WeChat Official Account QR Code

📄 License

RobustMQ is licensed under the Apache License 2.0, which strikes a balance between open collaboration and allowing you to use the software in your projects, whether open source or proprietary.

Built with ❤️ by the RobustMQ team and contributors.