jfinal mica-mqtt-server

<dependency>
	<groupId>net.dreamlu</groupId>
	<artifactId>jfinal-mica-mqtt-server</artifactId>
	<version>${最新版本}</version>
</dependency>

<dependency>
	<groupId>org.slf4j</groupId>
	<artifactId>slf4j-log4j12</artifactId>
	<version>1.7.33</version>
</dependency>

MqttServerPlugin plugin = new MqttServerPlugin();
plugin.config(mqttServerCreator -> {
    // mqttServerCreator 上有很多方法，详见 mica-mqttx-core
    mqttServerCreator.port(1883).webPort(8083).websocketEnable(true);
});

// 更多方法可以直接使用 MqttServerKit 点出来
MqttServerKit.publish(String clientId, String topic, ByteBuffer payload);