Можно ли прервать запрос http [GET, POST и т. Д.] В HttpAsynClient из HttpClient-5.x?

Question

Я использую org. apache .h c .client5.http.impl.asyn c .HttpAsyncClients.create () для создания org. apache .h c .client5.http .impl.asyn c .CloseableHttpAsyncClient для моих запросов HTTP / 2. Я ищу некоторые функции, чтобы прервать запрос после чтения некоторого количества данных из канала сокета.

Я пытался с помощью метода cancel (mayInterruptIfRunning) из экземпляра Future. Но после прерывания я не могу получить заголовки ответа и загруженный контент.

    Future<SimpleHttpResponse> future = null;
    CloseableHttpAsyncClient httpClient = null;
    try {
        httpClient = httpAsyncClientBuilder.build();
        httpClient.start();
        future = httpClient.execute(target, asyncRequestProducer, SimpleResponseConsumer.create(), null, this.httpClientContext, this);
        future.get(10, TimeUnit.SECONDS);
    } catch (Exception ex) {
        ex.printStackTrace();
    } finally {
        httpClient.close(CloseMode.GRACEFUL);
    }

Есть ли другой способ добиться этого с помощью httpclient-5.x?

Заранее спасибо.

Answer 1

Конечно, это так. Но вам нужно реализовать свой собственный пользовательский пользовательский ответ, который может возвращать частичное содержимое сообщения

try (CloseableHttpAsyncClient httpClient = HttpAsyncClients.createDefault()) {
    httpClient.start();

    final Future<Void> future = httpClient.execute(
            new BasicRequestProducer(Method.GET, new URI("http://httpbin.org/")),
            new AbstractCharResponseConsumer<Void>() {

                @Override
                protected void start(
                        final HttpResponse response,
                        final ContentType contentType) throws HttpException, IOException {
                    System.out.println(response.getCode());
                }

                @Override
                protected int capacityIncrement() {
                    return Integer.MAX_VALUE;
                }

                @Override
                protected void data(final CharBuffer src, final boolean endOfStream) throws IOException {
                }

                @Override
                protected Void buildResult() throws IOException {
                    return null;
                }

                @Override
                public void releaseResources() {
                }

            }, null, null);
    try {
        future.get(1, TimeUnit.SECONDS);
    } catch (TimeoutException ex) {
        future.cancel(true);
    }
}