mqtt优化

fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java

@@ -26,6 +26,9 @@ public class MqttConfiguration {
         options.setUserName(mqttPropertiesConfig.getUsername());
         options.setPassword(mqttPropertiesConfig.getPassword().toCharArray());
         options.setServerURIs(new String[]{mqttPropertiesConfig.getUrl()});
+        options.setAutomaticReconnect(true); // 启用自动重连
+        options.setConnectionTimeout(10); // 设置连接超时时间
+        options.setKeepAliveInterval(60); // 设置心跳间隔
         factory.setConnectionOptions(options);
         return factory;
     }