From 841c24a6ed739d8b23858476530b886442f6a099 Mon Sep 17 00:00:00 2001
From: wujiawei <1207537021@qq.com>
Date: Tue, 15 Jul 2025 16:20:06 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E6=B3=A8=E9=87=8Audp?=
 =?UTF-8?q?=E3=80=81=E9=80=9A=E9=81=93=E5=85=B3=E9=97=AD=E9=AA=8C=E8=AF=81?=
 =?UTF-8?q?=E9=80=9A=E9=81=93=E5=85=B3=E8=81=94=E9=80=9A=E9=81=93=E6=98=AF?=
 =?UTF-8?q?=E5=90=A6=E5=AD=98=E5=9C=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../NettyUdpServerSocketApplicationListener.java       |  2 +-
 .../heartbeat/server/init/InitServerSocket.java        |  3 ++-
 .../permeate/tcp/handler/NettyTcpServerHandler.java    | 10 +++++++---
 3 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/context/NettyUdpServerSocketApplicationListener.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/context/NettyUdpServerSocketApplicationListener.java
index 9acd891c..dc160ea7 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/context/NettyUdpServerSocketApplicationListener.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/context/NettyUdpServerSocketApplicationListener.java
@@ -15,7 +15,7 @@ import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodePr
 import org.springframework.stereotype.Component;
 
 @Slf4j
-@Component
+//@Component
 public class NettyUdpServerSocketApplicationListener implements SocketApplicationListener {
 
     private final EventLoopGroup bossGroup = "linux".equalsIgnoreCase(SystemPropertyUtil.get("os.name")) ? new EpollEventLoopGroup() : new NioEventLoopGroup();
diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerSocket.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerSocket.java
index 5d9cc228..be4ada17 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerSocket.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerSocket.java
@@ -16,7 +16,8 @@ import org.springframework.context.annotation.Import;
  */
 @Slf4j
 @Configuration
-@Import({NettyTcpServerSocketApplicationListener.class, NettyUdpServerSocketApplicationListener.class})
+@Import({NettyTcpServerSocketApplicationListener.class})
+//@Import({NettyTcpServerSocketApplicationListener.class, NettyUdpServerSocketApplicationListener.class})
 public class InitServerSocket {
 
 
diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/permeate/tcp/handler/NettyTcpServerHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/permeate/tcp/handler/NettyTcpServerHandler.java
index afefcd6a..2be80d86 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/permeate/tcp/handler/NettyTcpServerHandler.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/permeate/tcp/handler/NettyTcpServerHandler.java
@@ -119,12 +119,16 @@ public class NettyTcpServerHandler extends SimpleChannelInboundHandler<NettyProx
             log.warn("client: {} channel:{}, disconnect with visitorId:{}", clientId, channel.id().toString(), visitorId);
             // 访客通道 关闭访客通道
             NettyCommunicationIdContext.clear(visitorId);
-            // 关闭通信通道
             Channel nextChannel = ChannelAttributeKeyUtils.getNextChannel(channel);
             Channel transferNextChannel = ChannelAttributeKeyUtils.getTransferNextChannel(channel);
+            // 关闭通信通道
             channel.close();
-            nextChannel.close();
-            transferNextChannel.close();
+            if (ObjectUtils.isNotEmpty(nextChannel)) {
+                nextChannel.close();
+            }
+            if (ObjectUtils.isNotEmpty(transferNextChannel)) {
+                transferNextChannel.close();
+            }
             super.channelInactive(ctx);
         } else if (!ObjectUtils.isEmpty(clientId)) {
             // 断开客户端的连接:{}