From 8f904cf1b01827fd12e1b0e354e9a5439f4a4176 Mon Sep 17 00:00:00 2001
From: wujiawei <12345678>
Date: Wed, 17 Jan 2024 16:25:58 +0800
Subject: [PATCH] [fix] channel with no clientId

---
 .../server/netty/handler/NettyServerHandler.java    | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java
index e72d90c..04a4e79 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java
@@ -105,10 +105,13 @@ public class NettyServerHandler extends SimpleChannelInboundHandler<NettyProxyMs
 
         String clientId = ChannelAttributeKeyUtils.getClientId(channel);
         log.info("断开客户端的连接:{}", clientId);
-        NettyProxyMsg nettyMsg = new NettyProxyMsg();
-        nettyMsg.setType(MessageType.REPORT_CLIENT_DISCONNECTION);
-        nettyMsg.setClientId(clientId);
-        channelTypeAdapter.handler(channel, nettyMsg);
-        super.channelInactive(ctx);
+        if (!ObjectUtils.isEmpty(clientId)) {
+            NettyProxyMsg nettyMsg = new NettyProxyMsg();
+            nettyMsg.setType(MessageType.REPORT_CLIENT_DISCONNECTION);
+            nettyMsg.setClientId(clientId);
+            channelTypeAdapter.handler(channel, nettyMsg);
+            super.channelInactive(ctx);
+        }
+
     }
 }
\ No newline at end of file