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.testing.async;
28
29 import static org.hamcrest.MatcherAssert.assertThat;
30
31 import java.util.Random;
32 import java.util.concurrent.Executors;
33 import java.util.concurrent.Future;
34 import java.util.concurrent.ScheduledExecutorService;
35 import java.util.concurrent.TimeUnit;
36 import java.util.concurrent.TimeoutException;
37
38 import org.apache.hc.client5.http.async.methods.SimpleHttpResponse;
39 import org.apache.hc.client5.http.async.methods.SimpleRequestBuilder;
40 import org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient;
41 import org.apache.hc.client5.http.impl.async.HttpAsyncClients;
42 import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManager;
43 import org.apache.hc.client5.testing.extension.async.ClientProtocolLevel;
44 import org.apache.hc.client5.testing.extension.async.ServerProtocolLevel;
45 import org.apache.hc.client5.testing.extension.async.TestAsyncClient;
46 import org.apache.hc.core5.http.HeaderElements;
47 import org.apache.hc.core5.http.HttpHeaders;
48 import org.apache.hc.core5.http.HttpHost;
49 import org.apache.hc.core5.http.URIScheme;
50 import org.hamcrest.CoreMatchers;
51 import org.junit.jupiter.api.Test;
52 import org.junit.jupiter.params.ParameterizedTest;
53 import org.junit.jupiter.params.provider.ValueSource;
54
55 public abstract class TestHttp1Async extends AbstractHttpAsyncFundamentalsTest {
56
57 public TestHttp1Async(final URIScheme scheme) {
58 super(scheme, ClientProtocolLevel.STANDARD, ServerProtocolLevel.STANDARD);
59 }
60
61 @ParameterizedTest(name = "{displayName}; concurrent connections: {0}")
62 @ValueSource(ints = {5, 1, 20})
63 public void testSequentialGetRequestsCloseConnection(final int concurrentConns) throws Exception {
64 configureServer(bootstrap -> bootstrap.register("/random/*", AsyncRandomHandler::new));
65 final HttpHost target = startServer();
66
67 final TestAsyncClient client = startClient();
68
69 final PoolingAsyncClientConnectionManager connManager = client.getConnectionManager();
70 connManager.setDefaultMaxPerRoute(concurrentConns);
71 connManager.setMaxTotal(100);
72 for (int i = 0; i < 3; i++) {
73 final Future<SimpleHttpResponse> future = client.execute(
74 SimpleRequestBuilder.get()
75 .setHttpHost(target)
76 .setPath("/random/2048")
77 .addHeader(HttpHeaders.CONNECTION, HeaderElements.CLOSE)
78 .build(), null);
79 final SimpleHttpResponse response = future.get();
80 assertThat(response, CoreMatchers.notNullValue());
81 assertThat(response.getCode(), CoreMatchers.equalTo(200));
82 final String body = response.getBodyText();
83 assertThat(body, CoreMatchers.notNullValue());
84 assertThat(body.length(), CoreMatchers.equalTo(2048));
85 }
86 }
87
88 @Test
89 public void testSharedPool() throws Exception {
90 configureServer(bootstrap -> bootstrap.register("/random/*", AsyncRandomHandler::new));
91 final HttpHost target = startServer();
92
93 final TestAsyncClient client = startClient();
94
95 final PoolingAsyncClientConnectionManager connManager = client.getConnectionManager();
96 final Future<SimpleHttpResponse> future1 = client.execute(
97 SimpleRequestBuilder.get()
98 .setHttpHost(target)
99 .setPath("/random/2048")
100 .build(), null);
101 final SimpleHttpResponse response1 = future1.get();
102 assertThat(response1, CoreMatchers.notNullValue());
103 assertThat(response1.getCode(), CoreMatchers.equalTo(200));
104 final String body1 = response1.getBodyText();
105 assertThat(body1, CoreMatchers.notNullValue());
106 assertThat(body1.length(), CoreMatchers.equalTo(2048));
107
108
109 try (final CloseableHttpAsyncClient httpclient2 = HttpAsyncClients.custom()
110 .setConnectionManager(connManager)
111 .setConnectionManagerShared(true)
112 .build()) {
113 httpclient2.start();
114 final Future<SimpleHttpResponse> future2 = httpclient2.execute(
115 SimpleRequestBuilder.get()
116 .setHttpHost(target)
117 .setPath("/random/2048")
118 .build(), null);
119 final SimpleHttpResponse response2 = future2.get();
120 assertThat(response2, CoreMatchers.notNullValue());
121 assertThat(response2.getCode(), CoreMatchers.equalTo(200));
122 final String body2 = response2.getBodyText();
123 assertThat(body2, CoreMatchers.notNullValue());
124 assertThat(body2.length(), CoreMatchers.equalTo(2048));
125 }
126
127 final Future<SimpleHttpResponse> future3 = client.execute(
128 SimpleRequestBuilder.get()
129 .setHttpHost(target)
130 .setPath("/random/2048")
131 .build(), null);
132 final SimpleHttpResponse response3 = future3.get();
133 assertThat(response3, CoreMatchers.notNullValue());
134 assertThat(response3.getCode(), CoreMatchers.equalTo(200));
135 final String body3 = response3.getBodyText();
136 assertThat(body3, CoreMatchers.notNullValue());
137 assertThat(body3.length(), CoreMatchers.equalTo(2048));
138 }
139
140 @Test
141 public void testRequestCancellation() throws Exception {
142 configureServer(bootstrap -> bootstrap.register("/random/*", AsyncRandomHandler::new));
143 final HttpHost target = startServer();
144
145 final TestAsyncClient client = startClient();
146 final PoolingAsyncClientConnectionManager connManager = client.getConnectionManager();
147 connManager.setDefaultMaxPerRoute(1);
148 connManager.setMaxTotal(1);
149
150 final ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
151 try {
152
153 for (int i = 0; i < 20; i++) {
154 final Future<SimpleHttpResponse> future = client.execute(
155 SimpleRequestBuilder.get()
156 .setHttpHost(target)
157 .setPath("/random/1000")
158 .build(), null);
159
160 executorService.schedule(new Runnable() {
161
162 @Override
163 public void run() {
164 future.cancel(true);
165 }
166 }, i % 5, TimeUnit.MILLISECONDS);
167
168 try {
169 future.get(TIMEOUT.getDuration(), TIMEOUT.getTimeUnit());
170 } catch (final TimeoutException ex) {
171 throw ex;
172 } catch (final Exception ignore) {
173 }
174 }
175
176 final Random rnd = new Random();
177 for (int i = 0; i < 20; i++) {
178 final Future<SimpleHttpResponse> future = client.execute(
179 SimpleRequestBuilder.get()
180 .setHttpHost(target)
181 .setPath("/random/1000")
182 .build(), null);
183
184 executorService.schedule(new Runnable() {
185
186 @Override
187 public void run() {
188 future.cancel(true);
189 }
190 }, rnd.nextInt(200), TimeUnit.MILLISECONDS);
191
192 try {
193 future.get(TIMEOUT.getDuration(), TIMEOUT.getTimeUnit());
194 } catch (final TimeoutException ex) {
195 throw ex;
196 } catch (final Exception ignore) {
197 }
198 }
199
200 for (int i = 0; i < 5; i++) {
201 final Future<SimpleHttpResponse> future = client.execute(
202 SimpleRequestBuilder.get()
203 .setHttpHost(target)
204 .setPath("/random/1000")
205 .build(), null);
206 final SimpleHttpResponse response = future.get(TIMEOUT.getDuration(), TIMEOUT.getTimeUnit());
207 assertThat(response, CoreMatchers.notNullValue());
208 assertThat(response.getCode(), CoreMatchers.equalTo(200));
209 }
210
211 } finally {
212 executorService.shutdownNow();
213 }
214 }
215
216 }