|
18 | 18 | import org.apache.http.auth.AuthScope; |
19 | 19 | import org.apache.http.auth.UsernamePasswordCredentials; |
20 | 20 | import org.apache.http.client.CredentialsProvider; |
| 21 | +import org.apache.http.config.Registry; |
| 22 | +import org.apache.http.config.RegistryBuilder; |
| 23 | +import org.apache.http.conn.socket.ConnectionSocketFactory; |
| 24 | +import org.apache.http.conn.socket.PlainConnectionSocketFactory; |
21 | 25 | import org.apache.http.impl.client.BasicCredentialsProvider; |
22 | 26 | import org.apache.http.impl.client.CloseableHttpClient; |
23 | 27 | import org.apache.http.impl.client.HttpClients; |
@@ -579,7 +583,20 @@ public CloseableHttpClient initSslHttpClient() throws WxPayException { |
579 | 583 | } |
580 | 584 |
|
581 | 585 | // 创建支持SSL的连接池管理器 |
582 | | - PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(); |
| 586 | + SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory( |
| 587 | + sslContext, |
| 588 | + new DefaultHostnameVerifier() |
| 589 | + ); |
| 590 | + |
| 591 | + Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder |
| 592 | + .<ConnectionSocketFactory>create() |
| 593 | + .register("https", sslsf) |
| 594 | + .register("http", PlainConnectionSocketFactory.getSocketFactory()) |
| 595 | + .build(); |
| 596 | + PoolingHttpClientConnectionManager connectionManager = |
| 597 | + new PoolingHttpClientConnectionManager(socketFactoryRegistry); |
| 598 | + |
| 599 | + // PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(); |
583 | 600 | connectionManager.setMaxTotal(this.maxConnTotal); |
584 | 601 | connectionManager.setDefaultMaxPerRoute(this.maxConnPerRoute); |
585 | 602 |
|
|
0 commit comments