2018-05-30 18:54:02 +08:00
parent ae8fb992fb
commit 7b5b0f34ff
1 changed files with 9 additions and 5 deletions
--- a/src/org/redkale/net/Response.java
+++ b/src/org/redkale/net/Response.java
@@ -251,11 +251,15 @@ public abstract class Response<C extends Context, R extends Request<C>> {
            }
            this.recycleListener = null;
        }
-        if (request.keepAlive && channel != null && channel.isOpen()) {
-            AsyncConnection conn = removeChannel();
-            this.recycle();
-            this.prepare();
-            new PrepareRunner(context, conn, null, this).run();
+        if (request.keepAlive && channel != null) {
+            if (channel.isOpen()) {
+                AsyncConnection conn = removeChannel();
+                this.recycle();
+                this.prepare();
+                new PrepareRunner(context, conn, null, this).run();
+            } else {
+                channel.dispose();
+            }
        } else {
            this.context.responsePool.accept(this);
        }