清除Context数据

Author: wangqifox

src/main/java/love/wangqi/context/ContextUtil.java

@@ -42,4 +42,11 @@ public static void setException(Channel channel, Exception exception) {
     public static Exception getException(Channel channel) {
         return channel.attr(Attributes.EXCEPTION).get();
     }
+
+    public static void clear(Channel channel) {
+        channel.attr(Attributes.REQUEST).set(null);
+        channel.attr(Attributes.RESPONSE).set(null);
+        channel.attr(Attributes.KEEPALIVE).set(null);
+        channel.attr(Attributes.EXCEPTION).set(null);
+    }
 }

src/main/java/love/wangqi/core/DefaultChannelWriteFinishListener.java

@@ -23,6 +23,7 @@ public void operationComplete(ChannelFuture future) throws Exception {
         logger.debug("======= serverChannelId: {}", channel.id());
 
         ContextUtil.getRequest(channel).release();
+        ContextUtil.clear(channel);
 
         if (!keepAlive) {
             channel.close();