RestTemplate + HttpClient 调用Https 接口

妖狐艹你老母 2021-06-24 13:58 685阅读 0赞

也可以参考：[https://www.cnblogs.com/miaoying/p/12956961.html][https_www.cnblogs.com_miaoying_p_12956961.html]

配置项：

//设置整个连接池最大连接数 根据自己的场景决定
        private int maxTotal;
    
        //路由是对maxTotal的细分
        private int defaultMaxPerRoute;
    
        //服务器返回数据(response)的时间，超过该时间抛出read timeout
        private int socketTimeout;
    
        //连接上服务器(握手成功)的时间，超出该时间抛出connect timeout
        private int connectTimeout;
    
        //从连接池中获取连接的超时时间，超过该时间未拿到可用连接，会抛出        
        //org.apache.http.conn.ConnectionPoolTimeoutException
        private int connectionRequestTimeout;

连接池 Https+HttpClient配置

public HttpClient restTemplateConfigHttpClient() {
            TrustStrategy acceptingTrustStrategy = (x509Certificates, authType) -> true;
            SSLContext sslContext = null;
            try {
                sslContext = SSLContexts.custom().loadTrustMaterial(null, acceptingTrustStrategy).build();
            } catch (Exception e) {
                logger.error("sslContext异常", e);
            }
            SSLConnectionSocketFactory connectionSocketFactory =
                    new SSLConnectionSocketFactory(sslContext, new NoopHostnameVerifier());
    
            Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
                    .register("http", PlainConnectionSocketFactory.getSocketFactory())
                    .register("https", connectionSocketFactory)
                    .build();
            PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);
            // 设置整个连接池最大连接数 根据自己的场景决定
            connectionManager.setMaxTotal(this.maxTotal);
            // 路由是对maxTotal的细分
            connectionManager.setDefaultMaxPerRoute(this.defaultMaxPerRoute);
            RequestConfig requestConfig = RequestConfig.custom()
                    // 服务器返回数据(response)的时间，超过该时间抛出read timeout
                    .setSocketTimeout(this.socketTimeout)
                    // 连接上服务器(握手成功)的时间，超出该时间抛出connect timeout
                    .setConnectTimeout(this.connectTimeout)
                    // 从连接池中获取连接的超时时间，超过该时间未拿到可用连接，
                    // 会抛出org.apache.http.conn.ConnectionPoolTimeoutException:
                    // Timeout waiting for connection from pool
                    .setConnectionRequestTimeout(this.connectionRequestTimeout)
                    .build();
            return HttpClientBuilder.create()
                    .setDefaultRequestConfig(requestConfig)
                    .setConnectionManager(connectionManager)
                    .build();
        }

构造 ClientHttpRequestFactory ：

public ClientHttpRequestFactory httpRequestFactory() {
        return new HttpComponentsClientHttpRequestFactory(restTemplateConfigHttpClient());
    }

@Bean
    public RestTemplate restTemplate() {
        ClientHttpRequestFactory factory = httpRequestFactory();
        RestTemplate restTemplate = new RestTemplate(factory);
        restTemplate.setErrorHandler(new DefaultResponseErrorHandler() {
            @Override
            public void handleError(ClientHttpResponse response) throws IOException {
                if (response.getStatusCode() != HttpStatus.OK && response.getStatusCode() != HttpStatus.NOT_FOUND
                        && response.getStatusCode() != HttpStatus.FORBIDDEN && response.getStatusCode() != HttpStatus.BAD_REQUEST
                        && response.getStatusCode() != HttpStatus.UNAUTHORIZED
                ) {
                    super.handleError(response);
                }
            }
        });
        return restTemplate;
    }

[https_www.cnblogs.com_miaoying_p_12956961.html]: https://www.cnblogs.com/miaoying/p/12956961.html