diff --git a/app/src/main/java/qianmu/container/mqtt/MQTTService.java b/app/src/main/java/qianmu/container/mqtt/MQTTService.java
index 33672c0..65e872d 100644
--- a/app/src/main/java/qianmu/container/mqtt/MQTTService.java
+++ b/app/src/main/java/qianmu/container/mqtt/MQTTService.java
@@ -245,8 +245,10 @@ public class MQTTService extends Service {
         disconnectMqtt();
         stopSelf();
         try {
-            client.disconnect();
-        } catch (MqttException e) {
+            if (client != null) {
+                client.disconnect();
+            }
+        } catch (Exception e) {
             e.printStackTrace();
         }
         EventBus.getDefault().unregister(this);
@@ -464,7 +466,7 @@ public class MQTTService extends Service {
                 IMqttToken disconnectToken = client.disconnect();
 //                disconnectToken.waitForCompletion();
             }
-        } catch (MqttException e) {
+        } catch (Exception e) {
             LoggerUtil.e(TAG, "断开MQTT连接失败", e);
         }