在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
开源软件名称:mqtt-cluster开源软件地址:https://gitee.com/quickmsg/mqtt-cluster开源软件介绍:SMQTT开源的MQTT消息代理BrokerSMQTT基于reactor-netty(spring-webflux底层依赖)开发,底层采用Reactor3反应堆模型,支持单机部署,支持容器化部署,具备低延迟,高吞吐量,支持百万TCP连接,同时支持多种协议交互,是一款非常优秀的消息中间件! 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方式
在smqtt-bootstrap/target目录下生成jar
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.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地址管理后台监控页面Mqtt监控Jvm监控Netty监控License友情链接一款非常好用的IOT平台 thinglinks: 相关技术文档麻烦关注下公众号!
|
请发表评论