修改emq 参数

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/config/CcsMqttReceiveConfig.java

@@ -63,7 +63,8 @@ public class CcsMqttReceiveConfig {
         mqttConnectOptions.setUserName(userName);
         mqttConnectOptions.setPassword(password.toCharArray());
         mqttConnectOptions.setServerURIs(new String[]{hostUrl});
-        mqttConnectOptions.setKeepAliveInterval(20);
+        mqttConnectOptions.setKeepAliveInterval(10);
+        mqttConnectOptions.setMaxInflight(1000);
         mqttConnectOptions.setAutomaticReconnect(true);
 //        mqttConnectOptions.setConnectionTimeout(0);
         return mqttConnectOptions;

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/config/EquipmentIotMqttProduceConfig.java

@@ -48,7 +48,8 @@ public class EquipmentIotMqttProduceConfig {
         mqttConnectOptions.setUserName(userName);
         mqttConnectOptions.setPassword(password.toCharArray());
         mqttConnectOptions.setServerURIs(new String[]{hostUrl});
-        mqttConnectOptions.setKeepAliveInterval(2);
+        mqttConnectOptions.setKeepAliveInterval(10);
+        mqttConnectOptions.setMaxInflight(1000);
         mqttConnectOptions.setAutomaticReconnect(true);
 //        mqttConnectOptions.setConnectionTimeout(0);
         return mqttConnectOptions;

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/config/EquipmentIotMqttReceiveConfig.java

@@ -83,9 +83,11 @@ public class EquipmentIotMqttReceiveConfig {
         mqttConnectOptions.setUserName(userName);
         mqttConnectOptions.setPassword(password.toCharArray());
         mqttConnectOptions.setServerURIs(new String[]{hostUrl});
-        mqttConnectOptions.setKeepAliveInterval(20);
+        mqttConnectOptions.setKeepAliveInterval(10);
         mqttConnectOptions.setAutomaticReconnect(true);
+        mqttConnectOptions.setMaxInflight(1000);
 //        mqttConnectOptions.setConnectionTimeout(0);
+
         return mqttConnectOptions;
     }
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-fas-biz/src/main/java/com/yeejoin/amos/fas/business/action/mq/WebMqttSubscribe.java

@@ -57,7 +57,8 @@ public class WebMqttSubscribe {
         mqttConnectOptions.setUserName(userName);
         mqttConnectOptions.setPassword(password.toCharArray());
         mqttConnectOptions.setServerURIs(new String[]{hostUrl});
-        mqttConnectOptions.setKeepAliveInterval(2);
+        mqttConnectOptions.setKeepAliveInterval(10);
+        mqttConnectOptions.setMaxInflight(1000);
         mqttConnectOptions.setAutomaticReconnect(true);
         return mqttConnectOptions;
     }