diff --git a/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java b/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java
index 66aae6f..7c6e379 100644
--- a/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java
+++ b/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java
@@ -39,9 +39,9 @@ public class PtrMqttClient implements MqttCallback {
         options.setAutomaticReconnect(true);
         options.setUserName(username);
         options.setPassword(password.getBytes());
-        options.setConnectionTimeout(1);
+        options.setConnectionTimeout(5000);
         options.setKeepAliveInterval(20);
-        options.setExecutorServiceTimeout(1);
+        options.setExecutorServiceTimeout(5000);
 
         client.setCallback(this);
         client.connect(options);
diff --git a/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java b/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java
index 90a3532..2f84bc3 100644
--- a/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java
+++ b/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java
@@ -76,9 +76,9 @@ public class FrontendMessagePushService implements MqttCallback {
             options.setUserName(mqttConfig.getUsername());
             options.setPassword(mqttConfig.getPassword().getBytes());
             options.setAutomaticReconnect(true);
-            options.setConnectionTimeout(10);
+            options.setConnectionTimeout(5000);
             options.setKeepAliveInterval(60);
-            options.setExecutorServiceTimeout(1);
+            options.setExecutorServiceTimeout(5000);
 
             // 尝试连接
             int attempts = 0;