SMQTTX

English · 简体中文

✨ 核心特性

📋 点击展开完整功能列表

🚀 协议支持

• 标准MQTT协议 - 完整支持MQTT 3.1.1 & 5.0协议
• WebSocket协议 - 支持基于WebSocket的MQTT通信
• TLS/SSL加密 - 提供安全的加密通信
• HTTP协议 - 支持HTTP接口管理

🎯 服务质量

• QoS 0 - 至多一次投递
• QoS 1 - 至少一次投递
• QoS 2 - 仅一次投递

🔍 高级功能

• Topic过滤 - 支持通配符匹配
  • # 多级匹配
  • + 单级匹配
• 保留消息 - 消息持久化与重发
• 拦截器 - 自定义消息处理逻辑
• Metrics监控 - 全方位性能监控

⚙️ 规则引擎

• 规则管理 - 灵活的业务规则配置
• 数据源管理 - 多种数据源集成
• 实时计算 - 流式数据处理

🌐 分布式架构

• 集群支持 - 高可用分布式部署
• 动态路由 - 智能消息路由策略
• 节点发现 - 自动化集群管理
• 分布式任务 - 集群任务调度
• 负载均衡 - 高性能负载分发

🎮 管理平台

• Web管理界面 - 直观的可视化管理
• SpringBoot集成 - 简化开发集成
• 监控仪表板 - 实时性能监控

📖 项目介绍

🌟 SMQTTX 是基于 Java 21 开发的高性能、分布式MQTT消息代理服务器，专为物联网场景设计。

🏠 官方网站

• 🌐 项目官网
• 📚 在线文档
• 🎯 演示环境

🎯 项目背景

SMQTTX 基于 Reactor-Netty 构建高性能分布式MQTT集群，提供：

• 🚄 极致性能 - 单机支持百万级并发连接
• 🔧 简单配置 - 开箱即用，最小化配置
• 🌐 分布式 - 支持水平扩展，千万级设备接入
• 📊 可视化管理 - 统一管理平台，实时监控
• 🔌 易于集成 - SpringBoot Starter，一键启动

🚀 快速开始

📦 Maven依赖

✅ 环境要求: SpringBoot >= 3.0.0，Java >= 21

<dependency>
   <artifactId>smqttx-spring-boot-starter</artifactId>
   <groupId>io.github.quickmsg</groupId>
   <version>2.1.0</version>
</dependency>
<!-- 解决H2数据库版本冲突 -->
<dependency>
  <groupId>com.h2database</groupId>
  <artifactId>h2</artifactId>
  <version>1.4.197</version>
</dependency>

⚙️ 配置文件

在 application.yaml 中添加配置：

# 参考完整配置
# config/config.yaml

📋 完整配置文件参考

🎯 启动应用

在 SpringBoot 启动类上添加 @EnableMqttServer 注解：

@SpringBootApplication
@EnableMqttServer
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

📚 配置文档

配置模块	说明	文档链接
🔧 MQTT配置	基础MQTT服务配置	查看文档
🔐 ACL配置	访问控制列表配置	查看文档
🔑 Auth配置	认证授权配置	查看文档
🌐 HTTP配置	HTTP接口配置	查看文档
🔌 WebSocket配置	WebSocket协议配置	查看文档
🌍 集群配置	分布式集群配置	查看文档
🔒 SSL/TLS配置	安全传输配置	查看文档

维护者

感谢这些项目的维护者：

点我 打开/关闭 维护者列表

• MetaQ - SMQTTX项目维护者。

贡献者

感谢所有参与SMQTTX开发的贡献者。贡献者列表

组件

• Reactor-Netty - 高性能网络框架
• Reactor3 - 基于Reactor3的反应式框架实现
• Ignite - 基于高性能的分布式网络服务缓存
• WebSite - 项目官网
• Wiki - 项目文档

商业版本

商业版演示地址

有需要商业版接入的请添加微信18510240791联系我!

许可证

License APACHE 2.0

联系我们

请添加微信 17512575402 拉交流群