Skip to content

Main Navigation 首页博客文档

🖥️ Dashboard

📈 Prometheus

🔌 测试方式

📘 MQTT 5 Specification

📗 MQTT 3.1.1 Specification

📕 MQTT 3.1 Specification

📙 MQTT-SN v1.2

简体中文

简体中文

Sidebar Navigation

简介

什么是 RobustMQ

为什么有 RobustMQ

和主流MQ的对比

和 Kafka 对比

和 Pulsar 对比

和 NATS 对比

和 Redpanda 对比

和 Iggy 对比

RobustMQ 和现有MQ的对比

版本计划

2026 年 RoadMap

2025 年 RoadMap

MQTT Release 计划

Good First Issue

给我们签个名吧

快速启动

快速安装

公共Server

体验 RobustMQ MQTT

SDK 接入

安装部署

编译打包

二进制运行[单机]

二进制运行[集群]

Docker 模式

K8S 模式

系统架构

架构概览

Meta Service

Storage Adapter

Storage Engine

Connector

RobustMQ MQTT

概览

MQTT 核心概念

多租户

MQTT 系统架构

核心功能

共享订阅

保留消息

遗嘱消息

排他订阅

延迟发布

自动订阅

主题重写

通配符订阅

会话持久化

连接抖动

系统告警

系统主题

安全

数据源

概览

内置数据源（Meta Service）

MySQL

PostgreSQL

Redis

MongoDB

HTTP

认证

概览

Password

JWT

授权

黑名单

MQTTX 测试指南

客户端 SDK

使用 C SDK 连接

使用 Java SDK 连接

使用 Go SDK 连接

使用 Python SDK 连接

使用 JavaScript SDK 连接

参考指南

MQTT 教程

MQTT 5.0 协议

MQTT 3.1.1 协议

MQTT 术语

MQTT 5.0 特性

MQTT 原因码

RobustMQ Kafka

概览

协议支持

RobustMQ AMQP

概览

协议支持

RobustMQ 数据处理

概览

连接器

概述

本地文件

Kafka

Pulsar

RabbitMQ

GreptimeDB

PostgreSQL

MySQL

MongoDB

Elasticsearch

Redis

Webhook

OpenTSDB

MQTT 桥接

ClickHouse

InfluxDB

Cassandra

规则引擎

概述

算子列表

处理 Demo

RobustMQ 命令行

概览

集群管理

MQTT 管理

Engine 管理

RobustMQ 压测

Bench CLI 使用文档

MQTT Bench 使用文档

Meta Bench 使用文档

压测报告

管理员指南

Dashboard

健康检查

HTTP 接口文档

概览

Cluster API

MQTT API

Connector API

可观测性

Prometheus 接入

基础设施指标

MQTT 专用指标

Grafana 配置指南

配置说明

Broker 配置

日志配置

性能调优指南

贡献指南

GitHub 贡献指南

PR 提交示例

AI Skills 使用指南

代码贡献

环境搭建

Cargo运行

VSCode 运行

代码结构

Tokio Console

Pprof 使用指南

文档贡献

环境搭建

文档贡献指导

版本记录

0.3.0 RELEASE

0.2.0 RELEASE

目录

概览

RobustMQ 即将启动 RobustMQ AMQP 开发规划中

Pager

Previous page协议支持

Next page协议支持