org.apache.hc.client5.http.impl.io

Class BasicHttpClientConnectionManager

java.lang.Object

org.apache.hc.client5.http.impl.io.BasicHttpClientConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable, HttpClientConnectionManager, ModalCloseable

@Contract(threading=SAFE)
public class BasicHttpClientConnectionManager
extends Object
implements HttpClientConnectionManager

A connection manager for a single connection. This connection manager maintains only one active connection. Even though this class is fully thread-safe it ought to be used by one execution thread only, as only one thread a time can lease the connection at a time.

This connection manager will make an effort to reuse the connection for subsequent requests with the same route. It will, however, close the existing connection and open it for the given route, if the route of the persistent connection does not match that of the connection request. If the connection has been already been allocated IllegalStateException is thrown.

This connection manager implementation should be used inside an EJB container instead of PoolingHttpClientConnectionManager.

Since:

4.3

Constructor Summary

Constructors

Constructor and Description
BasicHttpClientConnectionManager()
BasicHttpClientConnectionManager(HttpClientConnectionOperator httpClientConnectionOperator, HttpConnectionFactory<ManagedHttpClientConnection> connFactory)
BasicHttpClientConnectionManager(Lookup<ConnectionSocketFactory> socketFactoryRegistry)
BasicHttpClientConnectionManager(Lookup<ConnectionSocketFactory> socketFactoryRegistry, HttpConnectionFactory<ManagedHttpClientConnection> connFactory)
BasicHttpClientConnectionManager(Lookup<ConnectionSocketFactory> socketFactoryRegistry, HttpConnectionFactory<ManagedHttpClientConnection> connFactory, SchemePortResolver schemePortResolver, DnsResolver dnsResolver)

Method Summary

Modifier and Type	Method and Description
void	close() Closes this stream and releases any system resources associated with it.
void	close(CloseMode closeMode) Closes this process or endpoint and releases any system resources associated with it.
void	closeExpired()
void	closeIdle(TimeValue idleTime)
void	connect(ConnectionEndpoint endpoint, TimeValue connectTimeout, HttpContext context) Connects the endpoint to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).
SocketConfig	getSocketConfig()
LeaseRequest	lease(String id, HttpRoute route, Object state)
LeaseRequest	lease(String id, HttpRoute route, Timeout requestTimeout, Object state) Returns a LeaseRequest object which can be used to obtain a ConnectionEndpoint to cancel the request by calling Cancellable.cancel().
void	release(ConnectionEndpoint endpoint, Object state, TimeValue keepAlive) Releases the endpoint back to the manager making it potentially re-usable by other consumers.
void	setSocketConfig(SocketConfig socketConfig)
void	upgrade(ConnectionEndpoint endpoint, HttpContext context) Upgrades transport security of the given endpoint by using the TLS security protocol.

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BasicHttpClientConnectionManager

public BasicHttpClientConnectionManager()

BasicHttpClientConnectionManager

public BasicHttpClientConnectionManager(HttpClientConnectionOperator httpClientConnectionOperator,
                                        HttpConnectionFactory<ManagedHttpClientConnection> connFactory)

Since:

4.4

BasicHttpClientConnectionManager

public BasicHttpClientConnectionManager(Lookup<ConnectionSocketFactory> socketFactoryRegistry)

BasicHttpClientConnectionManager

public BasicHttpClientConnectionManager(Lookup<ConnectionSocketFactory> socketFactoryRegistry,
                                        HttpConnectionFactory<ManagedHttpClientConnection> connFactory)

BasicHttpClientConnectionManager

public BasicHttpClientConnectionManager(Lookup<ConnectionSocketFactory> socketFactoryRegistry,
                                        HttpConnectionFactory<ManagedHttpClientConnection> connFactory,
                                        SchemePortResolver schemePortResolver,
                                        DnsResolver dnsResolver)

Method Detail

close

public void close()

Description copied from interface: Closeable

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

close

public void close(CloseMode closeMode)

Description copied from interface: ModalCloseable

Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.

Specified by:

close in interface ModalCloseable

Parameters:

closeMode - How to close the receiver.

closeExpired

public void closeExpired()

closeIdle

public void closeIdle(TimeValue idleTime)

connect

public void connect(ConnectionEndpoint endpoint,
                    TimeValue connectTimeout,
                    HttpContext context)
             throws IOException

Description copied from interface: HttpClientConnectionManager

Connects the endpoint to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).

Specified by:

connect in interface HttpClientConnectionManager

Parameters:

endpoint - the managed endpoint.

connectTimeout - connect timeout.

context - the actual HTTP context.

Throws:

IOException

getSocketConfig

public SocketConfig getSocketConfig()

lease

public LeaseRequest lease(String id,
                          HttpRoute route,
                          Object state)

lease

public LeaseRequest lease(String id,
                          HttpRoute route,
                          Timeout requestTimeout,
                          Object state)

Description copied from interface: HttpClientConnectionManager

Returns a LeaseRequest object which can be used to obtain a ConnectionEndpoint to cancel the request by calling Cancellable.cancel().

Please note that newly allocated endpoints can be leased disconnected. The consumer of the endpoint is responsible for fully establishing the route to the endpoint target by calling HttpClientConnectionManager.connect(ConnectionEndpoint, TimeValue, HttpContext) in order to connect directly to the target or to the first proxy hop, and optionally calling HttpClientConnectionManager.upgrade(ConnectionEndpoint, HttpContext) method to upgrade the underlying transport to Transport Layer Security after having executed a CONNECT method to all intermediate proxy hops.

Specified by:

lease in interface HttpClientConnectionManager

Parameters:

id - unique operation ID or null.

route - HTTP route of the requested connection.

requestTimeout - lease request timeout.

state - expected state of the connection or null if the connection is not expected to carry any state.

release

public void release(ConnectionEndpoint endpoint,
                    Object state,
                    TimeValue keepAlive)

Description copied from interface: HttpClientConnectionManager

Releases the endpoint back to the manager making it potentially re-usable by other consumers. Optionally, the maximum period of how long the manager should keep the connection alive can be defined using validDuration and timeUnit parameters.

Specified by:

release in interface HttpClientConnectionManager

Parameters:

endpoint - the managed endpoint.

state - the new connection state of null if state-less.

keepAlive - the duration of time this connection is valid for reuse.

setSocketConfig

public void setSocketConfig(SocketConfig socketConfig)

upgrade

public void upgrade(ConnectionEndpoint endpoint,
                    HttpContext context)
             throws IOException

Description copied from interface: HttpClientConnectionManager

Upgrades transport security of the given endpoint by using the TLS security protocol.

Specified by:

upgrade in interface HttpClientConnectionManager

Parameters:

endpoint - the managed endpoint.

context - the actual HTTP context.

Throws:

IOException