smqttx
smqttx copied to clipboard
An open source MQTT broker that supports access to tens of millions of devices (high-performance, scalable, cluster-supported based on reactor-netty)
SMQTTX
English · 简体中文
功能列表
点我 打开/关闭 功能列表
- 标准MQTT协议
- Websocket协议
- TLS/SSL加密
- 服务等级
- qos0 至多一次
- qos1 至少一次
- qos2 仅仅一次
- Topic过滤
- # 多级匹配
- + 一级匹配
- 保留消息
- HTTP协议
- 拦截器
- Metrics健康
- 规则引擎
- 规则管理
- 数据源管理
- 集群
- 分布式集群路由
- 分布式节点动态发现
- 分布式Job
- 集群互踢策略
- SMQTTX管理平台
- SpringBoot Starter
- Apacche 2
项目介绍
![]()
基于Java实现的物联网分布式MQTT消息代理服务器
官方网站
背景
基于Netty实现分布式MQTT集群,并提供快速接入、配置能力,提供统一的接入管理平台,无需复杂配置,即可完成千万级别设备接入。
快速入门
引入maven依赖
SpringBoot版本>=2.7.3
<dependency>
<artifactId>smqttx-spring-boot-starter</artifactId>
<groupId>io.github.quickmsg</groupId>
<version>2.0.11</version>
</dependency>
<!--屏蔽h2版本冲突-->
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<version>1.4.197</version>
</dependency>
配置文件
application.yaml中添加配置: 配置文件参考
启动服务
在SpringBootApplication启动类上添加
@EnableMqttServer ,然后启动服务即可
请关注一下配置文件:
| 配置项 | 参考文档 |
|---|---|
| mqtt配置 | https://wiki.smqtt.cc/smqttx/mqtt/1.mqtt.html |
| acl配置 | https://wiki.smqtt.cc/smqttx/acl/1.acl.html |
| auth配置 | https://wiki.smqtt.cc/smqttx/auth/1.auth.html |
| http配置 | https://wiki.smqtt.cc/smqttx/http/1.http.html |
| ws配置 | https://wiki.smqtt.cc/smqttx/ws/1.ws.html |
| cluster配置 | https://wiki.smqtt.cc/smqttx/cluster/1.cluster.html |
| ssl/tls配置 | https://wiki.smqtt.cc/smqttx/ssl/1.ssl.html |
维护者
点我 打开/关闭 维护者列表
- MetaQ - SMQTTX项目维护者。
贡献者
感谢所有参与SMQTTX开发的贡献者。贡献者列表
组件
- Reactor-Netty - 高性能网络框架
- Reactor3 - 基于Reactor3的反应式框架实现
- Ignite - 基于高性能的分布式网络服务缓存
- WebSite - 项目官网
- Wiki - 项目文档
商业版本
有需要商业版接入的请添加微信
18510240791联系我!
许可证
License APACHE 2.0
联系我们
请添加微信 17512575402 拉交流群