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

@@ -15,6 +15,8 @@
 import io.vertx.core.http.*;
 import io.vertx.core.internal.ContextInternal;
 import io.vertx.core.internal.http.HttpServerRequestInternal;
+import io.vertx.core.internal.logging.Logger;
+import io.vertx.core.internal.logging.LoggerFactory;
 import io.vertx.core.net.HostAndPort;
 import io.vertx.core.streams.Pipe;
 import io.vertx.httpproxy.Body;
@@ -25,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");
 
@@ -147,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/tests/ProxyClientKeepAliveTest.java

@@ -266,7 +266,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) {
@@ -279,13 +279,11 @@ 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);
     client = vertx.createHttpClient();
-    client.request(GET, 8081, "localhost", "/").onComplete(ctx.asyncAssertSuccess(req -> {
+    client.request(GET, 8080, "localhost", "/").onComplete(ctx.asyncAssertSuccess(req -> {
       req.send().onComplete(ctx.asyncAssertSuccess(resp -> {
         resp.handler(buff -> {
           resp.request().connection().close();