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