diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-20 18:27:11 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-20 18:27:11 -0700 |
| commit | b380b9e5d76c3c1b7170cf4abe6cdb5db71a48c0 (patch) | |
| tree | ed9f931deac76c4a548e73b711be2ed5329a2771 | |
| parent | 0e341a2a9a43d7556e27ef3739123a378dde3a53 (diff) | |
| download | seaweedfs-b380b9e5d76c3c1b7170cf4abe6cdb5db71a48c0.tar.xz seaweedfs-b380b9e5d76c3c1b7170cf4abe6cdb5db71a48c0.zip | |
shared http client
| -rw-r--r-- | other/java/client/src/main/java/seaweedfs/client/SeaweedUtil.java | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedUtil.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedUtil.java index e2835b718..c465d935f 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedUtil.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedUtil.java @@ -9,19 +9,22 @@ import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; public class SeaweedUtil { static PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(); + static CloseableHttpClient httpClient; static { // Increase max total connection to 200 cm.setMaxTotal(200); // Increase default max connection per route to 20 cm.setDefaultMaxPerRoute(20); - } - public static CloseableHttpClient getClosableHttpClient() { - return HttpClientBuilder.create() + httpClient = HttpClientBuilder.create() .setConnectionManager(cm) .setConnectionReuseStrategy(DefaultConnectionReuseStrategy.INSTANCE) .setKeepAliveStrategy(DefaultConnectionKeepAliveStrategy.INSTANCE) .build(); } + + public static CloseableHttpClient getClosableHttpClient() { + return httpClient; + } } |
