From 2a6b9eafb3b2e2de2d8574390f987b2019876d62 Mon Sep 17 00:00:00 2001
From: chenyouting <514333061@qq.com>
Date: Thu, 10 Jul 2025 09:43:40 +0800
Subject: [PATCH] =?UTF-8?q?mqtt=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/fuyuanshen/system/mqtt/config/MqttConfiguration.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java b/fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java
index 30ffadf..002b6b5 100644
--- a/fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java
+++ b/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;
     }