src/org/redkale/net/PrepareRunner.java

@@ -44,8 +44,8 @@ public final class PrepareRunner implements Runnable {
         final ObjectPool<? extends Response> responsePool = context.responsePool;
         if (data != null) { //BIO模式的UDP连接创建AsyncConnection时已经获取到ByteBuffer数据了
             if (response == null) response = responsePool.get();
-            response.init(channel);
             try {
+                response.init(channel);
                 prepare.prepare(data, response.request, response);
             } catch (Throwable t) {
                 context.logger.log(Level.WARNING, "prepare servlet abort, forece to close channel ", t);
@@ -91,10 +91,6 @@ public final class PrepareRunner implements Runnable {
                 public void failed(Throwable exc, Void attachment2) {
                     response.request.offerReadBuffer(buffer);
                     response.finish(true);
-                    try {
-                        channel.close();
-                    } catch (Exception e) {
-                    }
                     if (exc != null && context.logger.isLoggable(Level.FINEST)) {
                         context.logger.log(Level.FINEST, "Servlet Handler read channel erroneous, forece to close channel ", exc);
                     }
@@ -103,10 +99,6 @@ public final class PrepareRunner implements Runnable {
         } catch (Exception te) {
             response.request.offerReadBuffer(buffer);
             response.finish(true);
-            try {
-                channel.close();
-            } catch (Exception e) {
-            }
             if (te != null && context.logger.isLoggable(Level.FINEST)) {
                 context.logger.log(Level.FINEST, "Servlet read channel erroneous, forece to close channel ", te);
             }

src/org/redkale/net/Response.java

@@ -185,7 +185,7 @@ public abstract class Response<C extends Context, R extends Request<C>> {
         if (channel != null) {
             if (keepAlive) {
                 this.inited = false;
-                this.context.runAsync(new PrepareRunner(context, removeChannel(), null, this));
+                new PrepareRunner(context, removeChannel(), null, this).run();
                 return false;
             } else {
                 try {