✨ 优化 mqtt client 连接处理的逻辑。

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/DefaultMqttClientProcessor.java

@@ -108,7 +108,7 @@ public class DefaultMqttClientProcessor implements IMqttClientProcessor {
 			return;
 		}
 		try {
-			connectListener.onConnected(context);
+			connectListener.onConnected(context, context.isReconnect);
 		} catch (Throwable e) {
 			logger.error(e.getMessage(), e);
 		}

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/IMqttClientConnectListener.java

@@ -30,7 +30,8 @@ public interface IMqttClientConnectListener {
 	 * 监听到消息
 	 *
 	 * @param context     ChannelContext
+	 * @param isReconnect 是否重连
 	 */
-	void onConnected(ChannelContext context);
+	void onConnected(ChannelContext context, boolean isReconnect);
 
 }

mica-mqtt-example/src/main/java/net/dreamlu/iot/mqtt/client/MqttClientTest.java

@@ -48,8 +48,12 @@ public class MqttClientTest {
 //			.maxBytesInMessage(1024 * 10)
 			.version(MqttVersion.MQTT_5)
 //			连接监听
-			.connectListener((context) -> {
-				logger.info("连接服务器成功...");
+			.connectListener((context, isReconnect) -> {
+				if (isReconnect) {
+					logger.info("重连 mqtt 服务器成功...");
+				} else {
+					logger.info("连接 mqtt 服务器成功...");
+				}
 			})
 			.connect();