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
36 import javax.net.ssl.SSLContext;
37
38 import org.apache.hc.client5.http.DnsResolver;
39 import org.apache.hc.client5.http.HttpRoute;
40 import org.apache.hc.client5.http.SystemDefaultDnsResolver;
41 import org.apache.hc.client5.http.auth.StandardAuthScheme;
42 import org.apache.hc.client5.http.auth.CredentialsProvider;
43 import org.apache.hc.client5.http.classic.methods.HttpGet;
44 import org.apache.hc.client5.http.config.RequestConfig;
45 import org.apache.hc.client5.http.cookie.BasicCookieStore;
46 import org.apache.hc.client5.http.cookie.StandardCookieSpec;
47 import org.apache.hc.client5.http.cookie.CookieStore;
48 import org.apache.hc.client5.http.impl.auth.BasicCredentialsProvider;
49 import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
50 import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
51 import org.apache.hc.client5.http.impl.classic.HttpClients;
52 import org.apache.hc.client5.http.impl.io.ManagedHttpClientConnectionFactory;
53 import org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager;
54 import org.apache.hc.client5.http.io.ManagedHttpClientConnection;
55 import org.apache.hc.client5.http.protocol.HttpClientContext;
56 import org.apache.hc.client5.http.socket.ConnectionSocketFactory;
57 import org.apache.hc.client5.http.socket.PlainConnectionSocketFactory;
58 import org.apache.hc.client5.http.ssl.SSLConnectionSocketFactory;
59 import org.apache.hc.core5.http.ClassicHttpRequest;
60 import org.apache.hc.core5.http.ClassicHttpResponse;
61 import org.apache.hc.core5.http.Header;
62 import org.apache.hc.core5.http.HttpHost;
63 import org.apache.hc.core5.http.ParseException;
64 import org.apache.hc.core5.http.config.CharCodingConfig;
65 import org.apache.hc.core5.http.config.Http1Config;
66 import org.apache.hc.core5.http.config.Registry;
67 import org.apache.hc.core5.http.config.RegistryBuilder;
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.pool.PoolConcurrencyPolicy;
82 import org.apache.hc.core5.pool.PoolReusePolicy;
83 import org.apache.hc.core5.ssl.SSLContexts;
84 import org.apache.hc.core5.util.CharArrayBuffer;
85 import org.apache.hc.core5.util.TimeValue;
86 import org.apache.hc.core5.util.Timeout;
87
88
89
90
91
92 public class ClientConfiguration {
93
94 public final static void main(final String[] args) throws Exception {
95
96
97
98 final HttpMessageParserFactory<ClassicHttpResponse> responseParserFactory = new DefaultHttpResponseParserFactory() {
99
100 @Override
101 public HttpMessageParser<ClassicHttpResponse> create(final Http1Config h1Config) {
102 final LineParser lineParser = new BasicLineParser() {
103
104 @Override
105 public Header parseHeader(final CharArrayBuffer buffer) {
106 try {
107 return super.parseHeader(buffer);
108 } catch (final ParseException ex) {
109 return new BasicHeader(buffer.toString(), null);
110 }
111 }
112
113 };
114 return new DefaultHttpResponseParser(lineParser, DefaultClassicHttpResponseFactory.INSTANCE, h1Config);
115 }
116
117 };
118 final HttpMessageWriterFactory<ClassicHttpRequest> requestWriterFactory = new DefaultHttpRequestWriterFactory();
119
120
121 final Http1Config h1Config = Http1Config.custom()
122 .setMaxHeaderCount(200)
123 .setMaxLineLength(2000)
124 .build();
125
126 final CharCodingConfig connectionConfig = CharCodingConfig.custom()
127 .setMalformedInputAction(CodingErrorAction.IGNORE)
128 .setUnmappableInputAction(CodingErrorAction.IGNORE)
129 .setCharset(StandardCharsets.UTF_8)
130 .build();
131
132
133
134
135
136 final HttpConnectionFactory<ManagedHttpClientConnection> connFactory = new ManagedHttpClientConnectionFactory(
137 h1Config, connectionConfig, requestWriterFactory, responseParserFactory);
138
139
140
141
142
143
144
145
146 final SSLContext sslcontext = SSLContexts.createSystemDefault();
147
148
149
150 final Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create()
151 .register("http", PlainConnectionSocketFactory.INSTANCE)
152 .register("https", new SSLConnectionSocketFactory(sslcontext))
153 .build();
154
155
156 final DnsResolver dnsResolver = new SystemDefaultDnsResolver() {
157
158 @Override
159 public InetAddress[] resolve(final String host) throws UnknownHostException {
160 if (host.equalsIgnoreCase("myhost")) {
161 return new InetAddress[] { InetAddress.getByAddress(new byte[] {127, 0, 0, 1}) };
162 } else {
163 return super.resolve(host);
164 }
165 }
166
167 };
168
169
170 final PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(
171 socketFactoryRegistry, PoolConcurrencyPolicy.STRICT, PoolReusePolicy.LIFO, TimeValue.ofMinutes(5),
172 null, dnsResolver, null);
173
174
175 final SocketConfig socketConfig = SocketConfig.custom()
176 .setTcpNoDelay(true)
177 .build();
178
179
180 connManager.setDefaultSocketConfig(socketConfig);
181
182 connManager.setValidateAfterInactivity(TimeValue.ofSeconds(10));
183
184
185
186 connManager.setMaxTotal(100);
187 connManager.setDefaultMaxPerRoute(10);
188 connManager.setMaxPerRoute(new HttpRoute(new HttpHost("somehost", 80)), 20);
189
190
191 final CookieStore cookieStore = new BasicCookieStore();
192
193 final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
194
195 final RequestConfig defaultRequestConfig = RequestConfig.custom()
196 .setCookieSpec(StandardCookieSpec.STRICT)
197 .setExpectContinueEnabled(true)
198 .setTargetPreferredAuthSchemes(Arrays.asList(StandardAuthScheme.NTLM, StandardAuthScheme.DIGEST))
199 .setProxyPreferredAuthSchemes(Arrays.asList(StandardAuthScheme.BASIC))
200 .build();
201
202
203
204 try (final CloseableHttpClient httpclient = HttpClients.custom()
205 .setConnectionManager(connManager)
206 .setDefaultCookieStore(cookieStore)
207 .setDefaultCredentialsProvider(credentialsProvider)
208 .setProxy(new HttpHost("myproxy", 8080))
209 .setDefaultRequestConfig(defaultRequestConfig)
210 .build()) {
211 final HttpGet httpget = new HttpGet("http://httpbin.org/get");
212
213
214 final RequestConfig requestConfig = RequestConfig.copy(defaultRequestConfig)
215 .setConnectionRequestTimeout(Timeout.ofSeconds(5))
216 .setConnectTimeout(Timeout.ofSeconds(5))
217 .setProxy(new HttpHost("myotherproxy", 8080))
218 .build();
219 httpget.setConfig(requestConfig);
220
221
222 final HttpClientContext context = HttpClientContext.create();
223
224
225 context.setCookieStore(cookieStore);
226 context.setCredentialsProvider(credentialsProvider);
227
228 System.out.println("Executing request " + httpget.getMethod() + " " + httpget.getUri());
229 try (final CloseableHttpResponse response = httpclient.execute(httpget, context)) {
230 System.out.println("----------------------------------------");
231 System.out.println(response.getCode() + " " + response.getReasonPhrase());
232 System.out.println(EntityUtils.toString(response.getEntity()));
233
234
235
236
237
238
239 context.getRequest();
240
241 context.getHttpRoute();
242
243 context.getAuthExchanges();
244
245 context.getCookieOrigin();
246
247 context.getCookieSpec();
248
249 context.getUserToken();
250
251 }
252 }
253 }
254
255 }
256