/* * ==================================================================== * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * ==================================================================== * * This software consists of voluntary contributions made by many * individuals on behalf of the Apache Software Foundation. For more * information on the Apache Software Foundation, please see * . * */ package org.apache.http.nio.protocol; import java.io.Closeable; import java.io.IOException; import java.util.concurrent.Future; import org.apache.http.ConnectionClosedException; import org.apache.http.ConnectionReuseStrategy; import org.apache.http.HttpConnection; import org.apache.http.HttpHost; import org.apache.http.annotation.Immutable; import org.apache.http.concurrent.BasicFuture; import org.apache.http.concurrent.FutureCallback; import org.apache.http.nio.NHttpClientConnection; import org.apache.http.params.HttpParams; import org.apache.http.pool.ConnPool; import org.apache.http.pool.PoolEntry; import org.apache.http.protocol.BasicHttpContext; import org.apache.http.protocol.HttpContext; import org.apache.http.protocol.HttpProcessor; /** * HttpAsyncRequester is a utility class that can be used * in conjunction with {@link HttpAsyncRequestExecutor} to initiate execution * of asynchronous HTTP requests. * * @see HttpAsyncRequestExecutor * * @since 4.2 */ @Immutable public class HttpAsyncRequester { private final HttpProcessor httppocessor; private final ConnectionReuseStrategy reuseStrategy; private final HttpParams params; public HttpAsyncRequester( final HttpProcessor httppocessor, final ConnectionReuseStrategy reuseStrategy, final HttpParams params) { super(); this.httppocessor = httppocessor; this.reuseStrategy = reuseStrategy; this.params = params; } /** * Initiates asynchronous HTTP request execution. * * @param the result type of request execution. * @param requestProducer request producer callback. * @param responseConsumer response consumer callaback. * @param conn underlying HTTP connection. * @param context HTTP context * @param callback future callback. * @return future representing pending completion of the operation. */ public Future execute( final HttpAsyncRequestProducer requestProducer, final HttpAsyncResponseConsumer responseConsumer, final NHttpClientConnection conn, final HttpContext context, final FutureCallback callback) { if (requestProducer == null) { throw new IllegalArgumentException("HTTP request producer may not be null"); } if (responseConsumer == null) { throw new IllegalArgumentException("HTTP response consumer may not be null"); } if (conn == null) { throw new IllegalArgumentException("HTTP connection may not be null"); } if (context == null) { throw new IllegalArgumentException("HTTP context may not be null"); } BasicAsyncRequestExecutionHandler handler = new BasicAsyncRequestExecutionHandler( requestProducer, responseConsumer, callback, context, this.httppocessor, this.reuseStrategy, this.params); doExecute(handler, conn); return handler.getFuture(); } private void doExecute( final HttpAsyncRequestExecutionHandler handler, final NHttpClientConnection conn) { conn.getContext().setAttribute(HttpAsyncRequestExecutor.HTTP_HANDLER, handler); if (!conn.isOpen()) { handler.failed(new ConnectionClosedException("Connection closed")); try { handler.close(); } catch (IOException ex) { log(ex); } } else { conn.requestOutput(); } } /** * Initiates asynchronous HTTP request execution. * * @param the result type of request execution. * @param requestProducer request producer callback. * @param responseConsumer response consumer callaback. * @param conn underlying HTTP connection. * @param context HTTP context * @return future representing pending completion of the operation. */ public Future execute( final HttpAsyncRequestProducer requestProducer, final HttpAsyncResponseConsumer responseConsumer, final NHttpClientConnection conn, final HttpContext context) { return execute(requestProducer, responseConsumer, conn, context, null); } /** * Initiates asynchronous HTTP request execution. * * @param the result type of request execution. * @param requestProducer request producer callback. * @param responseConsumer response consumer callaback. * @param conn underlying HTTP connection. * @return future representing pending completion of the operation. */ public Future execute( final HttpAsyncRequestProducer requestProducer, final HttpAsyncResponseConsumer responseConsumer, final NHttpClientConnection conn) { return execute(requestProducer, responseConsumer, conn, new BasicHttpContext()); } /** * Initiates asynchronous HTTP request execution. * * @param the result type of request execution. * @param the connection pool entry type. * @param requestProducer request producer callback. * @param responseConsumer response consumer callaback. * @param connPool pool of persistent reusable connections. * @param context HTTP context * @param callback future callback. * @return future representing pending completion of the operation. */ public > Future execute( final HttpAsyncRequestProducer requestProducer, final HttpAsyncResponseConsumer responseConsumer, final ConnPool connPool, final HttpContext context, final FutureCallback callback) { if (requestProducer == null) { throw new IllegalArgumentException("HTTP request producer may not be null"); } if (responseConsumer == null) { throw new IllegalArgumentException("HTTP response consumer may not be null"); } if (connPool == null) { throw new IllegalArgumentException("HTTP connection pool may not be null"); } if (context == null) { throw new IllegalArgumentException("HTTP context may not be null"); } BasicFuture future = new BasicFuture(callback); HttpHost target = requestProducer.getTarget(); connPool.lease(target, null, new ConnRequestCallback( future, requestProducer, responseConsumer, connPool, context)); return future; } /** * Initiates asynchronous HTTP request execution. * * @param the result type of request execution. * @param the connection pool entry type. * @param requestProducer request producer callback. * @param responseConsumer response consumer callaback. * @param connPool pool of persistent reusable connections. * @param context HTTP context * @return future representing pending completion of the operation. */ public > Future execute( final HttpAsyncRequestProducer requestProducer, final HttpAsyncResponseConsumer responseConsumer, final ConnPool connPool, final HttpContext context) { return execute(requestProducer, responseConsumer, connPool, context, null); } /** * Initiates asynchronous HTTP request execution. * * @param the result type of request execution. * @param the connection pool entry type. * @param requestProducer request producer callback. * @param responseConsumer response consumer callaback. * @param connPool pool of persistent reusable connections. * @return future representing pending completion of the operation. */ public > Future execute( final HttpAsyncRequestProducer requestProducer, final HttpAsyncResponseConsumer responseConsumer, final ConnPool connPool) { return execute(requestProducer, responseConsumer, connPool, new BasicHttpContext()); } class ConnRequestCallback> implements FutureCallback { private final BasicFuture requestFuture; private final HttpAsyncRequestProducer requestProducer; private final HttpAsyncResponseConsumer responseConsumer; private final ConnPool connPool; private final HttpContext context; ConnRequestCallback( final BasicFuture requestFuture, final HttpAsyncRequestProducer requestProducer, final HttpAsyncResponseConsumer responseConsumer, final ConnPool connPool, final HttpContext context) { super(); this.requestFuture = requestFuture; this.requestProducer = requestProducer; this.responseConsumer = responseConsumer; this.connPool = connPool; this.context = context; } public void completed(final E result) { if (this.requestFuture.isDone()) { this.connPool.release(result, true); return; } NHttpClientConnection conn = result.getConnection(); BasicAsyncRequestExecutionHandler handler = new BasicAsyncRequestExecutionHandler( this.requestProducer, this.responseConsumer, new RequestExecutionCallback(this.requestFuture, result, this.connPool), this.context, httppocessor, reuseStrategy, params); doExecute(handler, conn); } public void failed(final Exception ex) { try { try { this.responseConsumer.failed(ex); } finally { releaseResources(); } } finally { this.requestFuture.failed(ex); } } public void cancelled() { try { try { this.responseConsumer.cancel(); } finally { releaseResources(); } } finally { this.requestFuture.cancel(true); } } public void releaseResources() { try { this.requestProducer.close(); } catch (IOException ioex) { log(ioex); } try { this.responseConsumer.close(); } catch (IOException ioex) { log(ioex); } } } class RequestExecutionCallback> implements FutureCallback { private final BasicFuture future; private final E poolEntry; private final ConnPool connPool; RequestExecutionCallback( final BasicFuture future, final E poolEntry, final ConnPool connPool) { super(); this.future = future; this.poolEntry = poolEntry; this.connPool = connPool; } public void completed(final T result) { try { this.connPool.release(this.poolEntry, true); } finally { this.future.completed(result); } } public void failed(final Exception ex) { try { this.connPool.release(this.poolEntry, false); } finally { this.future.failed(ex); } } public void cancelled() { try { this.connPool.release(this.poolEntry, false); } finally { this.future.cancel(true); } } } /** * This method can be used to log I/O exception thrown while closing {@link Closeable} * objects (such as {@link HttpConnection}}). * * @param ex I/O exception thrown by {@link Closeable#close()} */ protected void log(Exception ex) { } }