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) {