SMQTTX is a distributed MQTT cluster based on Java. It is a heavily upgraded version of SMQTT. It restructures the cluster manager of SMQTT and optimizes the access performance.

SMQTTX improves the function of distributed MQTT cluster, supports rule engine, persistence, ACL, device management, authentication management, publish and subscribe and other functions, thank you for using it.

quick start

Introduce maven dependency

SpringBoot version >= 2.7.3

<dependency>
   <artifactId>smqttx-spring-boot-starter</artifactId>
   <groupId>io.github.quickmsg</groupId>
   <version>2.0.3</version>
</dependency>
<!--屏蔽h2版本冲突-->
<dependency>
  <groupId>com.h2database</groupId>
  <artifactId>h2</artifactId>
  <version>1.4.197</version>
</dependency>

configuration file

Add configuration to application.yaml: Configuration file reference

start service

Add on the SpringBootApplication startup class @EnableMqttServer and then start the service

Please pay attention to the configuration file: