proxy httpclient does not release connection pool when frontend close chunked response (#90)

* Fix ProxyClientKeepAliveTest.testFrontendCloseChunkedResponse call method and port

* Fix proxy httpclient does not release connection pool when frontend close chunked response.

Author: hdfg159

src/main/java/io/vertx/httpproxy/impl/ProxiedRequest.java

@@ -10,19 +10,13 @@
  */
 package io.vertx.httpproxy.impl;
 
-import io.vertx.core.AsyncResult;
-import io.vertx.core.Future;
-import io.vertx.core.Handler;
-import io.vertx.core.MultiMap;
-import io.vertx.core.Promise;
+import io.vertx.core.*;
 import io.vertx.core.buffer.Buffer;
-import io.vertx.core.http.HttpClientRequest;
-import io.vertx.core.http.HttpHeaders;
-import io.vertx.core.http.HttpMethod;
-import io.vertx.core.http.HttpServerRequest;
-import io.vertx.core.http.HttpVersion;
+import io.vertx.core.http.*;
 import io.vertx.core.http.impl.HttpServerRequestInternal;
 import io.vertx.core.impl.ContextInternal;
+import io.vertx.core.impl.logging.Logger;
+import io.vertx.core.impl.logging.LoggerFactory;
 import io.vertx.core.net.HostAndPort;
 import io.vertx.core.streams.Pipe;
 import io.vertx.httpproxy.Body;
@@ -33,6 +27,7 @@
 import java.util.Objects;
 
 public class ProxiedRequest implements ProxyRequest {
+  private final static Logger log = LoggerFactory.getLogger(ProxiedRequest.class);
 
   private static final CharSequence X_FORWARDED_HOST = HttpHeaders.createOptimized("x-forwarded-host");
 
@@ -155,6 +150,14 @@ public ProxyResponse response() {
   }
 
   void sendRequest(Handler<AsyncResult<ProxyResponse>> responseHandler) {
+    proxiedRequest.connection().closeHandler(unused -> {
+      if (log.isTraceEnabled()) {
+        log.trace("Frontend connection closed,uri: " + proxiedRequest.uri());
+      }
+
+      request.reset();
+      proxiedRequest.response().reset();
+    });
 
     request.response().<ProxyResponse>map(r -> {
       r.pause(); // Pause it

src/test/java/io/vertx/httpproxy/ProxyClientKeepAliveTest.java

@@ -20,7 +20,6 @@
 import io.vertx.core.streams.WriteStream;
 import io.vertx.ext.unit.Async;
 import io.vertx.ext.unit.TestContext;
-import org.junit.Ignore;
 import org.junit.Test;
 
 import java.io.Closeable;
@@ -259,7 +258,7 @@ public void testFrontendCloseResponse(TestContext ctx) {
 
   @Test
   public void testFrontendCloseChunkedResponse(TestContext ctx) {
-    testBackendCloseResponse(ctx, true);
+    testFrontendCloseResponse(ctx, true);
   }
 
   private void testFrontendCloseResponse(TestContext ctx, boolean chunked) {
@@ -272,14 +271,12 @@ private void testFrontendCloseResponse(TestContext ctx, boolean chunked) {
         resp.putHeader("content-length", "10000");
       }
       resp.write("part");
-      resp.exceptionHandler(err -> {
-        async.complete();
-      });
+      resp.closeHandler(unused -> async.complete());
     });
     startProxy(backend);
     HttpClient client = vertx.createHttpClient();
-    client.request(GET, 8081, "localhost", "/", ctx.asyncAssertSuccess(req -> {
-      req.send(ctx.asyncAssertSuccess(resp -> {
+    client.request(GET, 8080, "localhost", "/").onComplete(ctx.asyncAssertSuccess(req -> {
+      req.send().onComplete(ctx.asyncAssertSuccess(resp -> {
         resp.handler(buff -> {
           resp.request().connection().close();
           System.out.println("closing");