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 java.util.concurrent.ExecutionException;
30 import java.util.concurrent.Future;
31 import java.util.concurrent.TimeUnit;
32 import java.util.function.Consumer;
33
34 import javax.net.ssl.SSLException;
35
36 import org.apache.hc.client5.http.impl.async.MinimalHttpAsyncClient;
37 import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManagerBuilder;
38 import org.apache.hc.client5.http.ssl.DefaultClientTlsStrategy;
39 import org.apache.hc.core5.http.HttpHost;
40 import org.apache.hc.core5.http.URIScheme;
41 import org.apache.hc.core5.http.config.Http1Config;
42 import org.apache.hc.core5.http.nio.AsyncClientEndpoint;
43 import org.apache.hc.core5.http2.config.H2Config;
44 import org.apache.hc.core5.ssl.SSLContexts;
45 import org.junit.jupiter.api.Assertions;
46 import org.junit.jupiter.api.Test;
47
48 public class TestHttpAsyncMinimalTlsHandshake extends AbstractIntegrationTestBase {
49
50 public TestHttpAsyncMinimalTlsHandshake() {
51 super(URIScheme.HTTPS);
52 }
53
54 protected MinimalHttpAsyncClient startMinimalClient(
55 final Consumer<PoolingAsyncClientConnectionManagerBuilder> connManagerCustomizer) throws Exception {
56 return startMinimalClient(
57 Http1Config.DEFAULT,
58 H2Config.DEFAULT,
59 connManagerCustomizer);
60 }
61
62 @Test
63 public void testSuccessfulTlsHandshake() throws Exception {
64 startServer(Http1Config.DEFAULT, null, null);
65 final HttpHost target = targetHost();
66
67 final int maxConnNo = 2;
68 final MinimalHttpAsyncClient client = startMinimalClient(builder -> builder
69 .setMaxConnPerRoute(maxConnNo)
70 .setMaxConnTotal(maxConnNo));
71
72 for (int i = 0; i < maxConnNo + 1; i++) {
73 final Future<AsyncClientEndpoint> endpointLease = client.lease(target, null);
74 final AsyncClientEndpoint endpoint = endpointLease.get(5, TimeUnit.SECONDS);
75 endpoint.releaseAndDiscard();
76 }
77 }
78
79 @Test
80 public void testTlsHandshakeFailure() throws Exception {
81 startServer(Http1Config.DEFAULT, null, null);
82 final HttpHost target = targetHost();
83
84 final int maxConnNo = 2;
85 final MinimalHttpAsyncClient client = startMinimalClient(builder -> builder
86 .setTlsStrategy(new DefaultClientTlsStrategy(SSLContexts.createDefault()))
87 .setMaxConnPerRoute(maxConnNo)
88 .setMaxConnTotal(maxConnNo));
89
90 for (int i = 0; i < maxConnNo + 1; i++) {
91 final Future<AsyncClientEndpoint> endpointLease = client.lease(target, null);
92 final ExecutionException executionException = Assertions.assertThrows(ExecutionException.class,
93 () -> endpointLease.get(5, TimeUnit.SECONDS));
94 Assertions.assertInstanceOf(SSLException.class, executionException.getCause());
95 }
96 }
97
98 }