diff --git a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/server/vertx/VertxMqttConnection.java b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/server/vertx/VertxMqttConnection.java
index 885cb3bf..b018aede 100644
--- a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/server/vertx/VertxMqttConnection.java
+++ b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/server/vertx/VertxMqttConnection.java
@@ -213,11 +213,15 @@ class VertxMqttConnection implements MqttConnection {
 
     @Override
     public InetSocketAddress getClientAddress() {
-        if (clientAddress == null) {
-            SocketAddress address = endpoint.remoteAddress();
-            if (address != null) {
-                clientAddress = new InetSocketAddress(address.host(), address.port());
+        try {
+            if (clientAddress == null && endpoint != null) {
+                SocketAddress address = endpoint.remoteAddress();
+                if (address != null) {
+                    clientAddress = new InetSocketAddress(address.host(), address.port());
+                }
             }
+        }catch (Throwable ignore){
+
         }
         return clientAddress;
     }