1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28 package org.apache.hc.client5.http.examples;
29
30 import java.net.InetAddress;
31 import java.net.UnknownHostException;
32 import java.nio.charset.CodingErrorAction;
33 import java.nio.charset.StandardCharsets;
34 import java.util.Arrays;
35 import java.util.Collections;
36
37 import javax.net.ssl.SSLContext;
38
39 import org.apache.hc.client5.http.ContextBuilder;
40 import org.apache.hc.client5.http.DnsResolver;
41 import org.apache.hc.client5.http.HttpRoute;
42 import org.apache.hc.client5.http.SystemDefaultDnsResolver;
43 import org.apache.hc.client5.http.auth.CredentialsProvider;
44 import org.apache.hc.client5.http.auth.StandardAuthScheme;
45 import org.apache.hc.client5.http.classic.methods.HttpGet;
46 import org.apache.hc.client5.http.config.ConnectionConfig;
47 import org.apache.hc.client5.http.config.RequestConfig;
48 import org.apache.hc.client5.http.config.TlsConfig;
49 import org.apache.hc.client5.http.cookie.BasicCookieStore;
50 import org.apache.hc.client5.http.cookie.CookieStore;
51 import org.apache.hc.client5.http.cookie.StandardCookieSpec;
52 import org.apache.hc.client5.http.impl.auth.CredentialsProviderBuilder;
53 import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
54 import org.apache.hc.client5.http.impl.classic.HttpClients;
55 import org.apache.hc.client5.http.impl.io.ManagedHttpClientConnectionFactory;
56 import org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager;
57 import org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManagerBuilder;
58 import org.apache.hc.client5.http.io.ManagedHttpClientConnection;
59 import org.apache.hc.client5.http.protocol.HttpClientContext;
60 import org.apache.hc.client5.http.ssl.SSLConnectionSocketFactory;
61 import org.apache.hc.core5.http.ClassicHttpRequest;
62 import org.apache.hc.core5.http.ClassicHttpResponse;
63 import org.apache.hc.core5.http.Header;
64 import org.apache.hc.core5.http.HttpHost;
65 import org.apache.hc.core5.http.ParseException;
66 import org.apache.hc.core5.http.config.CharCodingConfig;
67 import org.apache.hc.core5.http.config.Http1Config;
68 import org.apache.hc.core5.http.impl.io.DefaultClassicHttpResponseFactory;
69 import org.apache.hc.core5.http.impl.io.DefaultHttpRequestWriterFactory;
70 import org.apache.hc.core5.http.impl.io.DefaultHttpResponseParser;
71 import org.apache.hc.core5.http.impl.io.DefaultHttpResponseParserFactory;
72 import org.apache.hc.core5.http.io.HttpConnectionFactory;
73 import org.apache.hc.core5.http.io.HttpMessageParser;
74 import org.apache.hc.core5.http.io.HttpMessageParserFactory;
75 import org.apache.hc.core5.http.io.HttpMessageWriterFactory;
76 import org.apache.hc.core5.http.io.SocketConfig;
77 import org.apache.hc.core5.http.io.entity.EntityUtils;
78 import org.apache.hc.core5.http.message.BasicHeader;
79 import org.apache.hc.core5.http.message.BasicLineParser;
80 import org.apache.hc.core5.http.message.LineParser;
81 import org.apache.hc.core5.http.message.StatusLine;
82 import org.apache.hc.core5.http.ssl.TLS;
83 import org.apache.hc.core5.pool.PoolConcurrencyPolicy;
84 import org.apache.hc.core5.pool.PoolReusePolicy;
85 import org.apache.hc.core5.ssl.SSLContexts;
86 import org.apache.hc.core5.util.CharArrayBuffer;
87 import org.apache.hc.core5.util.TimeValue;
88 import org.apache.hc.core5.util.Timeout;
89
90
91
92
93
94 public class ClientConfiguration {
95
96 public final static void main(final String[] args) throws Exception {
97
98
99
100 final HttpMessageParserFactory<ClassicHttpResponse> responseParserFactory = new DefaultHttpResponseParserFactory() {
101
102 @Override
103 public HttpMessageParser<ClassicHttpResponse> create(final Http1Config h1Config) {
104 final LineParser lineParser = new BasicLineParser() {
105
106 @Override
107 public Header parseHeader(final CharArrayBuffer buffer) {
108 try {
109 return super.parseHeader(buffer);
110 } catch (final ParseException ex) {
111 return new BasicHeader(buffer.toString(), null);
112 }
113 }
114
115 };
116 return new DefaultHttpResponseParser(lineParser, DefaultClassicHttpResponseFactory.INSTANCE, h1Config);
117 }
118
119 };
120 final HttpMessageWriterFactory<ClassicHttpRequest> requestWriterFactory = new DefaultHttpRequestWriterFactory();
121
122
123 final Http1Config h1Config = Http1Config.custom()
124 .setMaxHeaderCount(200)
125 .setMaxLineLength(2000)
126 .build();
127
128 final CharCodingConfig connectionConfig = CharCodingConfig.custom()
129 .setMalformedInputAction(CodingErrorAction.IGNORE)
130 .setUnmappableInputAction(CodingErrorAction.IGNORE)
131 .setCharset(StandardCharsets.UTF_8)
132 .build();
133
134
135
136
137
138 final HttpConnectionFactory<ManagedHttpClientConnection> connFactory = new ManagedHttpClientConnectionFactory(
139 h1Config, connectionConfig, requestWriterFactory, responseParserFactory);
140
141
142
143
144
145
146
147
148 final SSLContext sslContext = SSLContexts.createSystemDefault();
149
150
151
152 final SSLConnectionSocketFactory sslConnectionSocketFactory = new SSLConnectionSocketFactory(sslContext);
153
154
155 final DnsResolver dnsResolver = new SystemDefaultDnsResolver() {
156
157 @Override
158 public InetAddress[] resolve(final String host) throws UnknownHostException {
159 if (host.equalsIgnoreCase("myhost")) {
160 return new InetAddress[] { InetAddress.getByAddress(new byte[] {127, 0, 0, 1}) };
161 } else {
162 return super.resolve(host);
163 }
164 }
165
166 };
167
168
169 final PoolingHttpClientConnectionManager connManager = PoolingHttpClientConnectionManagerBuilder.create()
170 .setSSLSocketFactory(sslConnectionSocketFactory)
171 .setConnectionFactory(connFactory)
172 .setDnsResolver(dnsResolver)
173 .setPoolConcurrencyPolicy(PoolConcurrencyPolicy.STRICT)
174 .setConnPoolPolicy(PoolReusePolicy.LIFO)
175 .build();
176
177
178
179 connManager.setDefaultSocketConfig(SocketConfig.custom()
180 .setTcpNoDelay(true)
181 .build());
182
183 connManager.setDefaultConnectionConfig(ConnectionConfig.custom()
184 .setConnectTimeout(Timeout.ofSeconds(30))
185 .setSocketTimeout(Timeout.ofSeconds(30))
186 .setValidateAfterInactivity(TimeValue.ofSeconds(10))
187 .setTimeToLive(TimeValue.ofHours(1))
188 .build());
189
190
191 connManager.setDefaultTlsConfig(TlsConfig.custom()
192 .setHandshakeTimeout(Timeout.ofSeconds(30))
193 .setSupportedProtocols(TLS.V_1_3)
194 .build());
195
196
197
198 connManager.setMaxTotal(100);
199 connManager.setDefaultMaxPerRoute(10);
200 connManager.setMaxPerRoute(new HttpRoute(new HttpHost("somehost", 80)), 20);
201
202
203 final CookieStore cookieStore = new BasicCookieStore();
204
205 final CredentialsProvider credentialsProvider = CredentialsProviderBuilder.create()
206 .build();
207
208 final RequestConfig defaultRequestConfig = RequestConfig.custom()
209 .setCookieSpec(StandardCookieSpec.STRICT)
210 .setExpectContinueEnabled(true)
211 .setTargetPreferredAuthSchemes(Arrays.asList(StandardAuthScheme.DIGEST))
212 .setProxyPreferredAuthSchemes(Collections.singletonList(StandardAuthScheme.BASIC))
213 .build();
214
215
216
217 try (final CloseableHttpClient httpclient = HttpClients.custom()
218 .setConnectionManager(connManager)
219 .setDefaultCookieStore(cookieStore)
220 .setDefaultCredentialsProvider(credentialsProvider)
221 .setProxy(new HttpHost("myproxy", 8080))
222 .setDefaultRequestConfig(defaultRequestConfig)
223 .build()) {
224 final HttpGet httpget = new HttpGet("http://httpbin.org/get");
225
226
227 final RequestConfig requestConfig = RequestConfig.copy(defaultRequestConfig)
228 .setConnectionRequestTimeout(Timeout.ofSeconds(5))
229 .build();
230 httpget.setConfig(requestConfig);
231
232
233
234
235 final HttpClientContext context = ContextBuilder.create()
236 .useCookieStore(cookieStore)
237 .useCredentialsProvider(credentialsProvider)
238 .build();
239
240 System.out.println("Executing request " + httpget.getMethod() + " " + httpget.getUri());
241 httpclient.execute(httpget, context, response -> {
242 System.out.println("----------------------------------------");
243 System.out.println(httpget + "->" + new StatusLine(response));
244 EntityUtils.consume(response.getEntity());
245 return null;
246 });
247
248 context.getRequest();
249
250 context.getHttpRoute();
251
252 context.getAuthExchanges();
253
254 context.getCookieOrigin();
255
256 context.getCookieSpec();
257
258 context.getUserToken();
259 }
260 }
261
262 }
263