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