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 package org.apache.hc.client5.http.examples;
28
29 import java.util.concurrent.CountDownLatch;
30 import java.util.concurrent.Future;
31 import java.util.concurrent.TimeUnit;
32
33 import org.apache.hc.client5.http.async.methods.SimpleHttpRequest;
34 import org.apache.hc.client5.http.async.methods.SimpleHttpResponse;
35 import org.apache.hc.client5.http.async.methods.SimpleRequestBuilder;
36 import org.apache.hc.client5.http.async.methods.SimpleRequestProducer;
37 import org.apache.hc.client5.http.async.methods.SimpleResponseConsumer;
38 import org.apache.hc.client5.http.config.TlsConfig;
39 import org.apache.hc.client5.http.impl.async.HttpAsyncClients;
40 import org.apache.hc.client5.http.impl.async.MinimalHttpAsyncClient;
41 import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManagerBuilder;
42 import org.apache.hc.core5.concurrent.FutureCallback;
43 import org.apache.hc.core5.http.HttpHost;
44 import org.apache.hc.core5.http.config.Http1Config;
45 import org.apache.hc.core5.http.message.StatusLine;
46 import org.apache.hc.core5.http.nio.AsyncClientEndpoint;
47 import org.apache.hc.core5.http2.HttpVersionPolicy;
48 import org.apache.hc.core5.http2.config.H2Config;
49 import org.apache.hc.core5.io.CloseMode;
50 import org.apache.hc.core5.reactor.IOReactorConfig;
51
52
53
54
55 public class AsyncClientHttp1Pipelining {
56
57 public static void main(final String[] args) throws Exception {
58
59 final MinimalHttpAsyncClient client = HttpAsyncClients.createMinimal(
60 H2Config.DEFAULT,
61 Http1Config.DEFAULT,
62 IOReactorConfig.DEFAULT,
63 PoolingAsyncClientConnectionManagerBuilder.create()
64 .setDefaultTlsConfig(TlsConfig.custom()
65 .setVersionPolicy(HttpVersionPolicy.FORCE_HTTP_1)
66 .build())
67 .build());
68
69 client.start();
70
71 final HttpHost target = new HttpHost("httpbin.org");
72 final Future<AsyncClientEndpoint> leaseFuture = client.lease(target, null);
73 final AsyncClientEndpoint endpoint = leaseFuture.get(30, TimeUnit.SECONDS);
74 try {
75 final String[] requestUris = new String[] {"/", "/ip", "/user-agent", "/headers"};
76
77 final CountDownLatch latch = new CountDownLatch(requestUris.length);
78 for (final String requestUri: requestUris) {
79 final SimpleHttpRequest request = SimpleRequestBuilder.get()
80 .setHttpHost(target)
81 .setPath(requestUri)
82 .build();
83
84 System.out.println("Executing request " + request);
85 endpoint.execute(
86 SimpleRequestProducer.create(request),
87 SimpleResponseConsumer.create(),
88 new FutureCallback<SimpleHttpResponse>() {
89
90 @Override
91 public void completed(final SimpleHttpResponse response) {
92 latch.countDown();
93 System.out.println(request + "->" + new StatusLine(response));
94 System.out.println(response.getBody());
95 }
96
97 @Override
98 public void failed(final Exception ex) {
99 latch.countDown();
100 System.out.println(request + "->" + ex);
101 }
102
103 @Override
104 public void cancelled() {
105 latch.countDown();
106 System.out.println(request + " cancelled");
107 }
108
109 });
110 }
111 latch.await();
112 } finally {
113 endpoint.releaseAndReuse();
114 }
115
116 System.out.println("Shutting down");
117 client.close(CloseMode.GRACEFUL);
118 }
119
120 }