✨ 优化 mica-mqtt-client 启动改为默认同步连接

lets-mica · Jan 11, 2024 · 750de97 · 750de97
1 parent 68f4340
commit 750de97
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -13,7 +13,7 @@
 
     <properties>
         <!-- mica-mqtt version -->
-        <revision>2.2.7</revision>
+        <revision>2.2.8-SNAPSHOT</revision>
         <!-- java version -->
         <java.version>1.8</java.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

diff --git a/...l-mica-mqtt-client/src/main/java/net/dreamlu/iot/mqtt/jfinal/client/MqttClientPlugin.java b/...l-mica-mqtt-client/src/main/java/net/dreamlu/iot/mqtt/jfinal/client/MqttClientPlugin.java
@@ -47,7 +47,13 @@ public void config(Consumer<MqttClientCreator> consumer) {
 	@Override
 	public boolean start() {
 		if (this.mqttClient == null) {
-			this.mqttClient = clientCreator.connect();
+			// 连接超时时间，如果没设置，改成 3s，减少因连不上卡顿时间
+			Integer timeout = clientCreator.getTimeout();
+			if (timeout == null) {
+				clientCreator.timeout(3);
+			}
+			// 使用同步连接
+			this.mqttClient = clientCreator.connectSync();
 		} else {
 			this.mqttClient.reconnect();
 		}