✨ 拆分 mica-mqtt-spring-boot-example

mica-mqtt-spring-boot-example/src/main/java/net/dreamlu/iot/mqtt/client/listener/MqttClientMessageListener.java

@@ -15,7 +15,7 @@ import java.nio.ByteBuffer;
  * @author L.cm
  */
 @Service
-@MqttClientSubscribe("/test/#")
+@MqttClientSubscribe("${topic1}")
 public class MqttClientMessageListener implements IMqttClientMessageListener {
 	private static final Logger logger = LoggerFactory.getLogger(MqttClientMessageListener.class);
 

mica-mqtt-spring-boot-example/src/main/java/net/dreamlu/iot/mqtt/client/listener/MqttClientSubscribeListener.java

@@ -18,7 +18,7 @@ import java.nio.ByteBuffer;
 public class MqttClientSubscribeListener {
 	private static final Logger logger = LoggerFactory.getLogger(MqttClientSubscribeListener.class);
 
-	@MqttClientSubscribe("/test/#")
+	@MqttClientSubscribe("/test1/#")
 	public void subQos0(String topic, ByteBuffer payload) {
 		logger.info("topic:{} payload:{}", topic, ByteBufferUtil.toString(payload));
 	}

mica-mqtt-spring-boot-example/src/main/resources/application-client.yml

@@ -19,3 +19,4 @@ mqtt:
     buffer-allocator: heap      # 堆内存和堆外内存，默认：堆内存
     keep-alive-secs: 60         # keep-alive 时间，单位：秒
     clean-session: true         # mqtt clean session，默认：true
+topic1: /test2/#