如何使用PoolightTPClientConnectionManager设置连接超时？

Question

因为我计划从v.3升级httpclient依赖项。第1至第4节。5.13，但后来我意识到，许多功能已经改变，其中之一就是多线程HttpConnectionManager已经从最新版本中删除。当我搜索一个等价类时，stackoverflow HttpClient 4中的一篇文章——多线程HttpConnectionManager发生了什么事？，建议使用PoolightTPClientConnectionManager类。但是，我想设置连接超时和套接字超时，PoolightTPClientConnectionManager不提供这些功能。

final MultiThreadedHttpConnectionManager connectionManager = new MultiThreadedHttpConnectionManager();
        connectionManager.setMaxTotalConnections(150);
        connectionManager.setMaxConnectionsPerHost(90);
        connectionManager.setConnectionTimeout(15000);
        connectionManager.setSoTimeout(600000);

有谁能建议在最近的httpclient v.4中如何设置连接超时和套接字超时。5.x？

Answer 1

这是我的代码：

java prettyprint-override">    private static class HttpPool {

        private static CloseableHttpClient httpClient;
        private static final int TIME_OUT = 30;
        private static PoolingHttpClientConnectionManager cm;

        public static void init() {
            cm = new PoolingHttpClientConnectionManager();
            cm.setDefaultMaxPerRoute(200);
            cm.setMaxTotal(100);
            cm.setDefaultMaxPerRoute(20);
            HttpHost localhost = new HttpHost("locahost", 80);
            cm.setMaxPerRoute(new HttpRoute(localhost), 50);
            
            ConnectionKeepAliveStrategy kaStrategy = new DefaultConnectionKeepAliveStrategy() {
                @Override
                public long getKeepAliveDuration(HttpResponse response, HttpContext context) {
                    long keepAlive = super.getKeepAliveDuration(response, context);
                    if (keepAlive == -1) {
                        keepAlive = 0;
                    }
                    return keepAlive;
                }

            };
            SocketConfig socketConfig = SocketConfig.custom()
                    .setSoKeepAlive(false)
                    .setSoLinger(1)
                    .setSoReuseAddress(true)
                    .setSoTimeout(TIME_OUT)
                    .setTcpNoDelay(true).build();
            
            RequestConfig config = RequestConfig.custom()
                    .setConnectTimeout(TIME_OUT)
                    .setConnectionRequestTimeout(TIME_OUT)
                    .setSocketTimeout(TIME_OUT).build();
            
            httpClient = HttpClients.custom()
                    .setConnectionManager(cm)
                    .setKeepAliveStrategy(kaStrategy)
                    .setDefaultRequestConfig(config)
                    .setDefaultSocketConfig(socketConfig)
                    .setRetryHandler((IOException exception, int executionCount, HttpContext context) -> false)
                    .build();
            
            new Thread(() -> new Timer().schedule(new TimerTask() {
                @Override
                public void run() {
                    // Close expired connections
                    cm.closeExpiredConnections();
                    // Optionally, close connections
                    // that have been idle longer than 30 sec
                    cm.closeIdleConnections(30, TimeUnit.SECONDS);
                }
            }, 0, 5000)).start();
            
        }

        public static CloseableHttpClient getClient() {
            if (httpClient == null) {
                synchronized (HttpPool.class) {
                    if (httpClient == null) {
                        init();
                    }
                }
            }
            return httpClient;
        }

    }

有些代码是从其他代码复制的，如果有错误，请指出