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