diff --git a/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java b/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java
index 674db69..c956bc7 100755
--- a/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java
+++ b/mqtt-plugin/src/main/java/cc/iotkit/plugins/mqtt/service/MqttVerticle.java
@@ -215,6 +215,9 @@ public class MqttVerticle extends AbstractVerticle implements Handler<MqttEndpoi
             endpointMap.remove(deviceName);
             MQTT_CONNECT_POOL.put(clientId, false);
             DEVICE_ONLINE.clear();
+        }).pingHandler(msg->{
+            // 心跳 ping
+            ping(productKey,deviceName);
         }).subscribeHandler(subscribe -> {
             List<MqttSubAckReasonCode> reasonCodes = new ArrayList<>();
             for (MqttTopicSubscription s : subscribe.topicSubscriptions()) {
@@ -418,6 +421,18 @@ public class MqttVerticle extends AbstractVerticle implements Handler<MqttEndpoi
         }
     }
 
+    private void ping(String productKey, String deviceName) {
+        thingService.post(
+                pluginInfo.getPluginId(),
+                fillAction(
+                        DevicePing.builder()
+                                .productKey(productKey)
+                                .deviceName(deviceName)
+                                .build()
+                )
+        );
+    }
+
     private void offline(String productKey, String deviceName) {
         thingService.post(
                 pluginInfo.getPluginId(),