Estoy usando org.apache.hc.client5.http.impl.async.HttpAsyncClients.create() para crear org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient para mis solicitudes HTTP/2. Estoy buscando alguna funcionalidad para abortar la solicitud después de leer cierta cantidad de datos del canal de socket.
probé con el método cancel (mayInterruptIfRunning) de la instancia de Future. Pero después de cancelarlo, no puedo obtener los encabezados de respuesta y el contenido descargado.
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); }¿Hay alguna otra forma de lograr esto con httpclient-5.x?
Gracias por adelantado.
Por supuesto que es. Pero debe implementar su propio consumidor de respuesta personalizado que pueda devolver un contenido de mensaje parcial
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); } }