Browse Source

shared http client

pull/1397/head
Chris Lu 5 years ago
parent
commit
b380b9e5d7
  1. 9
      other/java/client/src/main/java/seaweedfs/client/SeaweedUtil.java

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

@ -9,19 +9,22 @@ import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
public class SeaweedUtil { public class SeaweedUtil {
static PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(); static PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
static CloseableHttpClient httpClient;
static { static {
// Increase max total connection to 200 // Increase max total connection to 200
cm.setMaxTotal(200); cm.setMaxTotal(200);
// Increase default max connection per route to 20 // Increase default max connection per route to 20
cm.setDefaultMaxPerRoute(20); cm.setDefaultMaxPerRoute(20);
}
public static CloseableHttpClient getClosableHttpClient() {
return HttpClientBuilder.create()
httpClient = HttpClientBuilder.create()
.setConnectionManager(cm) .setConnectionManager(cm)
.setConnectionReuseStrategy(DefaultConnectionReuseStrategy.INSTANCE) .setConnectionReuseStrategy(DefaultConnectionReuseStrategy.INSTANCE)
.setKeepAliveStrategy(DefaultConnectionKeepAliveStrategy.INSTANCE) .setKeepAliveStrategy(DefaultConnectionKeepAliveStrategy.INSTANCE)
.build(); .build();
} }
public static CloseableHttpClient getClosableHttpClient() {
return httpClient;
}
} }
Loading…
Cancel
Save