1.3.2

other/java/client/src/main/java/seaweedfs/client/SeaweedRead.java

@@ -93,8 +93,11 @@ public class SeaweedRead {
 
             data = EntityUtils.toByteArray(entity);
 
+            EntityUtils.consume(entity);
+
         } finally {
             response.close();
+            request.releaseConnection();
         }
 
         if (chunkView.isCompressed) {

other/java/client/src/main/java/seaweedfs/client/SeaweedUtil.java

@@ -1,7 +1,8 @@
 package seaweedfs.client;
 
-import org.apache.http.client.HttpClient;
+import org.apache.http.impl.DefaultConnectionReuseStrategy;
 import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.DefaultConnectionKeepAliveStrategy;
 import org.apache.http.impl.client.HttpClientBuilder;
 import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
 
@@ -19,6 +20,8 @@ public class SeaweedUtil {
     public static CloseableHttpClient getClosableHttpClient() {
         return HttpClientBuilder.create()
                 .setConnectionManager(cm)
+                .setConnectionReuseStrategy(DefaultConnectionReuseStrategy.INSTANCE)
+                .setKeepAliveStrategy(DefaultConnectionKeepAliveStrategy.INSTANCE)
                 .build();
     }
 }

other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java

@@ -7,6 +7,7 @@ import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.entity.mime.HttpMultipartMode;
 import org.apache.http.entity.mime.MultipartEntityBuilder;
+import org.apache.http.util.EntityUtils;
 
 import java.io.ByteArrayInputStream;
 import java.io.Closeable;
@@ -111,9 +112,12 @@ public class SeaweedWrite {
                 etag = etag.substring(1, etag.length() - 1);
             }
 
+            EntityUtils.consume(response.getEntity());
+
             return etag;
         } finally {
             response.close();
+            post.releaseConnection();
         }
 
     }