From b660fd94c2d8ba3af8bd4b7bb7241af35e5b6cb5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=B8=89=E4=B8=99?=
 <10604541+sanbing-os@user.noreply.gitee.com>
Date: Sat, 13 Sep 2025 17:03:59 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E5=88=9B=E5=BB=BA=E5=90=8E?=
 =?UTF-8?q?=E4=B8=8D=E5=8F=91=E6=8A=A5=E6=96=87=EF=BC=8Cctx=E5=8F=AF?=
 =?UTF-8?q?=E8=83=BD=E4=B8=BA=E7=A9=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/sanbing/jcpp/protocol/listener/tcp/TcpSession.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpSession.java b/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpSession.java
index 6a881e9..a78f1ad 100644
--- a/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpSession.java
+++ b/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpSession.java
@@ -85,8 +85,10 @@ public class TcpSession extends ProtocolSession {
     public void close(SessionCloseReason reason) {
         super.close(reason);
 
-        ctx.flush();
-        ctx.close();
+        if (ctx != null) {
+            ctx.flush();
+            ctx.close();
+        }
     }
 
     public void writeAndFlush(ByteBuf byteBuf) {