Перейти к основному содержимому

Учебное пособие по Apache HttpAsyncClient

· 4 мин. чтения

Упражнение: Сложение двух чисел

Даны два неотрицательный целых числа в виде непустых связных списков. Их цифры хранятся в обратном порядке. И каждый елемент списка содержить ровно одну цифру. Сложите эти два числа и верните сумму в виде связного списка ...

ANDROMEDA

1. Обзор

В этом руководстве мы проиллюстрируем наиболее распространенные варианты использования Apache HttpAsyncClient — от базового использования до настройки прокси-сервера , использования SSL-сертификата и, наконец, аутентификации с помощью асинхронного клиента. ``

2. Простой пример

Сначала — давайте посмотрим, как использовать HttpAsyncClient на простом примере — отправьте запрос GET:

@Test
public void whenUseHttpAsyncClient_thenCorrect() throws Exception {
CloseableHttpAsyncClient client = HttpAsyncClients.createDefault();
client.start();
HttpGet request = new HttpGet("http://www.google.com");

Future<HttpResponse> future = client.execute(request, null);
HttpResponse response = future.get();
assertThat(response.getStatusLine().getStatusCode(), equalTo(200));
client.close();
}

Обратите внимание, что нам нужно запустить асинхронный клиент перед его использованием ; без этого мы получили бы следующее исключение:

java.lang.IllegalStateException: Request cannot be executed; I/O reactor status: INACTIVE
at o.a.h.u.Asserts.check(Asserts.java:46)
at o.a.h.i.n.c.CloseableHttpAsyncClientBase.
ensureRunning(CloseableHttpAsyncClientBase.java:90)

3. Многопоточность с HttpAsyncClient

Теперь давайте посмотрим, как использовать HttpAsyncClient для одновременного выполнения нескольких запросов.

В следующем примере мы отправляем три запроса GET на три разных хоста, используя HttpAsyncClient и PoolingNHttpClientConnectionManager :

@Test
public void whenUseMultipleHttpAsyncClient_thenCorrect() throws Exception {
ConnectingIOReactor ioReactor = new DefaultConnectingIOReactor();
PoolingNHttpClientConnectionManager cm =
new PoolingNHttpClientConnectionManager(ioReactor);
CloseableHttpAsyncClient client =
HttpAsyncClients.custom().setConnectionManager(cm).build();
client.start();

String[] toGet = {
"http://www.google.com/",
"http://www.apache.org/",
"http://www.bing.com/"
};

GetThread[] threads = new GetThread[toGet.length];
for (int i = 0; i < threads.length; i++) {
HttpGet request = new HttpGet(toGet[i]);
threads[i] = new GetThread(client, request);
}

for (GetThread thread : threads) {
thread.start();
}
for (GetThread thread : threads) {
thread.join();
}
}

Вот наша реализация GetThread для обработки ответа:

static class GetThread extends Thread {
private CloseableHttpAsyncClient client;
private HttpContext context;
private HttpGet request;

public GetThread(CloseableHttpAsyncClient client,HttpGet req){
this.client = client;
context = HttpClientContext.create();
this.request = req;
}

@Override
public void run() {
try {
Future<HttpResponse> future = client.execute(request, context, null);
HttpResponse response = future.get();
assertThat(response.getStatusLine().getStatusCode(), equalTo(200));
} catch (Exception ex) {
System.out.println(ex.getLocalizedMessage());
}
}
}

4. Прокси с HttpAsyncClient

Далее — давайте посмотрим, как настроить и использовать прокси с HttpAsyncClient .

В следующем примере мы отправляем запрос HTTP GET через прокси :

@Test
public void whenUseProxyWithHttpClient_thenCorrect() throws Exception {
CloseableHttpAsyncClient client = HttpAsyncClients.createDefault();
client.start();

HttpHost proxy = new HttpHost("74.50.126.248", 3127);
RequestConfig config = RequestConfig.custom().setProxy(proxy).build();
HttpGet request = new HttpGet("https://issues.apache.org/");
request.setConfig(config);

Future<HttpResponse> future = client.execute(request, null);
HttpResponse response = future.get();

assertThat(response.getStatusLine().getStatusCode(), equalTo(200));
client.close();
}

5. SSL-сертификат с HttpAsyncClient

Теперь давайте посмотрим, как использовать SSL-сертификат с HttpAsyncClient .

В следующем примере мы настраиваем HttpAsyncClient для приема всех сертификатов :

@Test
public void whenUseSSLWithHttpAsyncClient_thenCorrect() throws Exception {
TrustStrategy acceptingTrustStrategy = new TrustStrategy() {
public boolean isTrusted(X509Certificate[] certificate, String authType) {
return true;
}
};
SSLContext sslContext = SSLContexts.custom()
.loadTrustMaterial(null, acceptingTrustStrategy).build();

CloseableHttpAsyncClient client = HttpAsyncClients.custom()
.setSSLHostnameVerifier(SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER)
.setSSLContext(sslContext).build();
client.start();

HttpGet request = new HttpGet("https://mms.nw.ru/");
Future<HttpResponse> future = client.execute(request, null);
HttpResponse response = future.get();

assertThat(response.getStatusLine().getStatusCode(), equalTo(200));
client.close();
}

Далее — давайте посмотрим, как использовать куки с HttpAsyncClient .

В следующем примере мы устанавливаем значение cookie перед отправкой запроса :

@Test
public void whenUseCookiesWithHttpAsyncClient_thenCorrect() throws Exception {
BasicCookieStore cookieStore = new BasicCookieStore();
BasicClientCookie cookie = new BasicClientCookie("JSESSIONID", "1234");
cookie.setDomain(".github.com");
cookie.setPath("/");
cookieStore.addCookie(cookie);

CloseableHttpAsyncClient client = HttpAsyncClients.custom().build();
client.start();

HttpGet request = new HttpGet("http://www.github.com");
HttpContext localContext = new BasicHttpContext();
localContext.setAttribute(HttpClientContext.COOKIE_STORE, cookieStore);
Future<HttpResponse> future = client.execute(request, localContext, null);
HttpResponse response = future.get();

assertThat(response.getStatusLine().getStatusCode(), equalTo(200));
client.close();
}

7. Аутентификация с помощью HttpAsyncClient

Далее — давайте посмотрим, как использовать аутентификацию с помощью HttpAsyncClient .

В следующем примере мы используем CredentialsProvider для доступа к хосту через обычную аутентификацию:

@Test
public void whenUseAuthenticationWithHttpAsyncClient_thenCorrect() throws Exception {
CredentialsProvider provider = new BasicCredentialsProvider();
UsernamePasswordCredentials creds = new UsernamePasswordCredentials("user", "pass");
provider.setCredentials(AuthScope.ANY, creds);

CloseableHttpAsyncClient client =
HttpAsyncClients.custom().setDefaultCredentialsProvider(provider).build();
client.start();

HttpGet request = new HttpGet("http://localhost:8080");
Future<HttpResponse> future = client.execute(request, null);
HttpResponse response = future.get();

assertThat(response.getStatusLine().getStatusCode(), equalTo(200));
client.close();
}

8. Заключение

В этой статье мы проиллюстрировали различные варианты использования асинхронного HTTP-клиента Apache.

Реализацию всех этих примеров и фрагментов кода можно найти в моем проекте на github — это проект на основе Eclipse, поэтому его легко импортировать и запускать как есть.