smqttx

nodemq

mqtt-cluster

smqtt-springboot

SMQTT重磅升级

感谢大家帮忙给新项目点Star,感谢!

• Gitee
• image SMQTT开源的MQTT消息代理Broker

  SMQTT基于reactor-netty(spring-webflux底层依赖) 开发,底层采用Reactor3反应堆模型,支持单机部署,支持容器化部署,具备低延迟,高吞吐量,支持百万TCP连接,同时支持多种协议交互,是一款非常优秀的消息中间件!

  smqtt目前拥有的功能如下:

  架构图

  1. 消息质量等级实现(支持qos0,qos1,qos2)

  2. topicFilter支持

     • topic分级(test/test)
     • +支持(单层匹配)
     • *支持(多层匹配)

  3. 会话消息

     • 默认内存存储
     • 支持持久化(redis/db)

  4. 保留消息

     • 默认内存存储
     • 支持持久化(redis/db)

  5. 遗嘱消息

     设备掉线时候触发

  6. 客户端认证

     • 支持spi注入外部认证

  7. tls加密

     • 支持tls加密(mqtt端口/http端口)

  8. websocket协议支持x

     使用mqtt over websocket

  9. http协议交互

     • 支持http接口推送消息
     • 支持spi扩展http接口

  10. SPI接口扩展支持

      • 消息管理接口(会话消息/保留消息管理)
      • 通道管理接口 (管理系统的客户端连接)
      • (削除) 认证接口 (用于自定义外部认证) (削除ここまで)
      • 拦截器 (用户自定义拦截消息)

  11. 集群支持(gossip协议实现)

  12. 容器化支持

      默认镜像最新tag: 1ssqq1lxr/smqtt

  13. 持久化支持(session 保留消息)

  14. 规则引擎支持

  15. 支持springboot starter启动

  16. 管理后台

      请参考smqtt文档如何启动管理后台

  17. grafana监控集成

      • 支持influxdb
      • 支持prometheus

  18. ACL权限管理

      • 对设备、资访问授权

  19. 认证模块

      • 支持http
      • 支持匿名
      • 支持固定密码
      • 支持sql

  尝试一下

  大家不要恶意链接,谢谢!

  管理	说明	其他
  121.40.92.152:1883	mqtt端口	用户名:smqtt 密码:smqtt
  121.40.92.152:18888	mqtt over websocket	用户名:smqtt 密码:smqtt
  启动方式 main方式启动 引入依赖 <!--smqtt依赖 --> <dependency> <groupId>io.github.quickmsg</groupId> <artifactId>smqtt-core</artifactId> <version>${Latest version}</version> </dependency> <!--集群依赖 --> <dependency> <artifactId>smqtt-registry-scube</artifactId> <groupId>io.github.quickmsg</groupId> <version>${Latest version}</version> </dependency> <!--管理ui依赖 --> <dependency> <artifactId>smqtt-ui</artifactId> <groupId>io.github.quickmsg</groupId> <version>${Latest version}</version> </dependency> 阻塞式启动服务: Bootstrap.builder() .rootLevel(Level.INFO) .websocketConfig( BootstrapConfig.WebsocketConfig .builder() .enable(false) .path("/mqtt") .port(8888) .build() ) .tcpConfig( BootstrapConfig .TcpConfig .builder() .port(1883) .ssl(SslContext.builder().enable(false).build()) .build()) .httpConfig( BootstrapConfig .HttpConfig .builder() .enable(false) .accessLog(true) .admin(BootstrapConfig.HttpAdmin.builder().enable(true).username("smqtt").password("smqtt").build()) .build()) .clusterConfig( BootstrapConfig. ClusterConfig .builder() .enable(false) .namespace("smqtt") .node("node-1") .port(7773) .url("127.0.0.1:7771,127.0.0.1:7772"). build()) .build() .startAwait(); 非阻塞式启动服务: Bootstrap bootstrap = Bootstrap.builder() .rootLevel(Level.INFO) .websocketConfig( BootstrapConfig.WebsocketConfig .builder() .enable(false) .path("/mqtt") .port(8888) .build() ) .tcpConfig( BootstrapConfig .TcpConfig .builder() .port(1883) .ssl(SslContext.builder().enable(false).build()) .build()) .httpConfig( BootstrapConfig .HttpConfig .builder() .enable(false) .accessLog(true) .admin(BootstrapConfig.HttpAdmin.builder().enable(true).username("smqtt").password("smqtt").build()) .build()) .clusterConfig( BootstrapConfig. ClusterConfig .builder() .enable(false) .namespace("smqtt") .node("node-1") .port(7773) .url("127.0.0.1:7771,127.0.0.1:7772"). build()) .build() .start().block(); jar方式 下载源码 mvn compile package -Dmaven.test.skip=true -P jar,web 在smqtt-bootstrap/target目录下生成jar 准备配置文件 config.yaml config.yaml 启动服务 java -jar smqtt-bootstrap-1.0.1-SNAPSHOT.jar <config.yaml路径> docker 方式 拉取镜像 # 拉取docker镜像地址 docker pull 1ssqq1lxr/smqtt:latest 启动镜像默认配置 # 启动服务 docker run -it -p 1883:1883 1ssqq1lxr/smqtt 启动镜像使用自定义配置(同上准备配置文件config.yaml) # 启动服务 docker run -it -v <配置文件路径目录>:/conf -p 1883:1883 -p 1999:1999 1ssqq1lxr/smqtt springboot方式 引入依赖 <dependency> <groupId>io.github.quickmsg</groupId> <artifactId>smqtt-spring-boot-starter</artifactId> <version>${Latest version >= 1.0.8}</version> </dependency> 启动类Application上添加注解 @EnableMqttServer 配置application.yml文件 properties也支持,但是需要自己转换,没有提供demo文件 config.yaml 启动springboot服务服务即可 如果引入的是spring-boot-starter-parent的管理包,如果启动报错,则需要添加以下依赖 <dependency> <groupId>io.projectreactor</groupId> <artifactId>reactor-core</artifactId> <version>3.4.9</version> </dependency> <dependency> <groupId>io.projectreactor.netty</groupId> <artifactId>reactor-netty</artifactId> <version>1.0.10</version> </dependency> 官网地址 wiki地址 管理后台 image 监控页面 Mqtt监控 image Jvm监控 image Netty监控 image License Apache License, Version 2.0 商业版本 友情链接 一款非常好用的IOT平台 thinglinks: Gitee 相关技术文档 reactor-netty 麻烦关注下公众号! image 添加微信号Lemon877164954,拉入smqtt官方交流群 加入qq群 700152283 成就 4 仓库 2 PR 1.5K Star 535 Fork 仓库语言 Java 43% Vue 23% JavaScript 18% Python 13% CSS 3% HTML 1% SCSS <1% Less <1% Shell <1% 其他 <1% 成员(9) 8701 xmqtt 1762567557 出言有尺 护国神将-小将 908397 leafseelight 1701065004 叶见光 jy 8062911 wx b178a99695 1600039520 赵鹏 问天 9091604 quickmsg admin 1631676370 quickmsg DamonPanda 吴伟坚 点此查找更多帮助 搜索帮助 Git 命令在线学习 如何在 Gitee 导入 GitHub 仓库 Git 仓库基础操作 企业版和社区版功能对比 SSH 公钥设置 如何处理代码冲突 仓库体积过大,如何减小? 如何找回被删除的仓库数据 Gitee 产品配额说明 GitHub仓库快速导入Gitee及同步更新 什么是 Release(发行版) 将 PHP 项目自动发布到 packagist.org 回到顶部 AltStyle によって変換されたページ (->オリジナル) / アドレス: モード: デフォルト 音声ブラウザ ルビ付き 配色反転 文字拡大 モバイル