A list,

Mica-mqtt is a simple, low latency, high performance MQTT Iot open source component based on t-IO implementation. See the mica-MQtt-example module for details.

Second, the function of

• Supports MQTT V3.1, V3.1.1 and V5.0 protocols.
• Support MQTT Client client.
• Supports MQTT Server server.
• Support MQTT will message.
• MQTT retention messages are supported.
• Support for custom message (MQ) processing forwarding implementation clusters.
• MQTT client Aliyun MQTT connection to Demo.
• Support quick access to Spring Boot projects (MICA-MQTT-spring-boot-starter).

Third, to do

• Added Websocket support (preresearched successfully).
• Optimized for MQTT session handling and support for V5.0

Update records

• subscription management is integrated into session management.
• MqttProperties. MqttPropertyType add comments, consider the MQTT V5.0 new features.
• Add the Spring Boot starter to facilitate access and support Spring Boot of earlier versions.
• Investigate the T-IO Websocket sub-protocol.
• fixes some problems with Java 8 runtime, NoSuchMethodError: java.nio.bytebuffer.xxx

Fast access to Spring Boot

5.1 Adding a Dependency

<dependency>
    <groupId>net.dreamlu</groupId>
    <artifactId>mica-mqtt-spring-boot-starter</artifactId>
    <version>1.0.1</version>
</dependency>
Copy the code

5.2 configuration items

5.3 Implementable Interface (Register as Spring Bean)

5.4 (Optional) Custom Configuration

@Configuration(proxyBeanMethods = false)
public class MqttServerCustomizerConfiguration {

	@Bean
	public MqttServerCustomizer activeRecordPluginCustomizer(a) {
		return new MqttServerCustomizer() {
			@Override
			public void customize(MqttServerCreator creator) {
				// You can customize the configuration creator here, which overwrites the configuration in YML
				System.out.println("----------------MqttServerCustomizer-----------------"); }}; }}Copy the code

Common Java project access

6.1 the maven rely on

 <dependency>
   <groupId>net.dreamlu</groupId>
   <artifactId>mica-mqtt-core</artifactId>
   <version>1.0.1</version>
 </dependency>
Copy the code

6.2 MicA-MQTT client

 // Initialize MQTT client
 MqttClient client = MqttClient.create()
     .ip("127.0.0.1")
     .port(1883)                     // Default: 1883
     .username("admin")
     .password("123456")
     .version(MqttVersion.MQTT_5)    // Default: 3_1_1
     .clientId("xxxxxx")             // Default: the mica-mqtt - prefix and nanoseconds in base 36
     .connect();                     / / the connection
 
     // Message subscription, similar method subxxx
     client.subQos0("/test/#", (topic, payload) -> {
         logger.info(topic + '\t' + ByteBufferUtil.toString(payload));
     });
     // Unsubscribe
     client.unSubscribe("/test/#");
 
     // Send a message
     client.publish("/test/client", ByteBuffer.wrap("Mica's best skin.".getBytes(StandardCharsets.UTF_8)));
 
     // Disconnect the connection
     client.disconnect();
     / / reconnection
     client.reconnect();
     / / stop
     client.stop();
Copy the code

6.3 MicA-MQTT Server

 // Note: Add the JVM parameter -xss129k in order to accept more links (lower memory)
 MqttServer mqttServer = MqttServer.create()
     // Default: 127.0.0.1
     .ip("127.0.0.1")
     // Default: 1883
     .port(1883)
     // Default: 8092 (MQTT default maximum message size), can be reduced to reduce memory, if the message is too large t-IO will try to parse multiple times (recommended according to the actual service situation)
     .readBufferSize(512)
     // Custom authentication
     .authHandler((clientId, userName, password) -> true)
     // Message listener
     .messageListener((clientId, topic, mqttQoS, payload) -> {
         logger.info("clientId:{} topic:{} mqttQoS:{} message:{}", clientId, topic, mqttQoS, ByteBufferUtil.toString(payload));
     })
     / / the SSL configuration
     .useSsl("".""."")
     // Customize client up-down and down-line listening
     .connectStatusListener(new IMqttConnectStatusListener() {
         @Override
         public void online(String clientId) {}@Override
         public void offline(String clientId) {}})// Custom message forwarding, which can be clustered using MQ broadcast
     .messageDispatcher(new IMqttMessageDispatcher() {
         @Override
         public void config(MqttServer mqttServer) {}@Override
         public boolean send(Message message) {
             return false;
         }
 
         @Override
         public boolean send(String clientId, Message message) {
             return false;
         }
     })
     .debug() // Enable t-IO debug information logs
     .start();
 
 // Send to a client
 mqttServer.publish("clientId"."/test/123", ByteBuffer.wrap("Mica's best skin.".getBytes()), MqttQoS.EXACTLY_ONCE);
 
 // send to all clients listening to this topic online
 mqttServer.publishAll("/test/123", ByteBuffer.wrap("Mica's best skin.".getBytes()), MqttQoS.EXACTLY_ONCE);
 
 // Stop the service
 mqttServer.stop();
Copy the code

7. Effect demonstration

Viii. Relevant documents

• Mica-mqtt-spring-boot-starter uses documentation
• Mica-mqtt uses documentation
• Mica-mqtt release
• T-io official document
• MQTT protocol documents