depends.org.apache.http.impl.conn

类 PoolingHttpClientConnectionManager

java.lang.Object

depends.org.apache.http.impl.conn.PoolingHttpClientConnectionManager

所有已实现的接口:

HttpClientConnectionManager, ConnPoolControl<HttpRoute>, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public class PoolingHttpClientConnectionManager
extends java.lang.Object
implements HttpClientConnectionManager, ConnPoolControl<HttpRoute>, java.io.Closeable

ClientConnectionPoolManager maintains a pool of HttpClientConnections and is able to service connection requests from multiple execution threads. Connections are pooled on a per route basis. A request for a route which already the manager has persistent connections for available in the pool will be services by leasing a connection from the pool rather than creating a brand new connection.

ClientConnectionPoolManager maintains a maximum limit of connection on a per route basis and in total. Per default this implementation will create no more than than 2 concurrent connections per given route and no more 20 connections in total. For many real-world applications these limits may prove too constraining, especially if they use HTTP as a transport protocol for their services. Connection limits, however, can be adjusted using ConnPoolControl methods.

从以下版本开始:

4.3

构造器概要

构造器

构造器和说明
PoolingHttpClientConnectionManager()
PoolingHttpClientConnectionManager(HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory)
PoolingHttpClientConnectionManager(long timeToLive, java.util.concurrent.TimeUnit tunit)
PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry)
PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry, DnsResolver dnsResolver)
PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry, HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory)
PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry, HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory, DnsResolver dnsResolver)
PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry, HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory, SchemePortResolver schemePortResolver, DnsResolver dnsResolver, long timeToLive, java.util.concurrent.TimeUnit tunit)

方法概要

方法

限定符和类型	方法和说明
void	close()
void	closeExpiredConnections() Closes all expired connections in the pool.
void	closeIdleConnections(long idleTimeout, java.util.concurrent.TimeUnit tunit) Closes idle connections in the pool.
void	connect(HttpClientConnection managedConn, HttpRoute route, int connectTimeout, HttpContext context) Connects the underlying connection socket to the 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).
protected void	finalize()
ConnectionConfig	getConnectionConfig(HttpHost host)
ConnectionConfig	getDefaultConnectionConfig()
int	getDefaultMaxPerRoute()
SocketConfig	getDefaultSocketConfig()
int	getMaxPerRoute(HttpRoute route)
int	getMaxTotal()
SocketConfig	getSocketConfig(HttpHost host)
PoolStats	getStats(HttpRoute route)
PoolStats	getTotalStats()
protected HttpClientConnection	leaseConnection(java.util.concurrent.Future<depends.org.apache.http.impl.conn.CPoolEntry> future, long timeout, java.util.concurrent.TimeUnit tunit)
void	releaseConnection(HttpClientConnection managedConn, java.lang.Object state, long keepalive, java.util.concurrent.TimeUnit tunit) Releases the connection back to the manager making it potentially re-usable by extension consumers.
ConnectionRequest	requestConnection(HttpRoute route, java.lang.Object state) Returns a new ConnectionRequest, from which a HttpClientConnection can be obtained or the request can be aborted.
void	routeComplete(HttpClientConnection managedConn, HttpRoute route, HttpContext context) Marks the connection as fully established with all its intermediate hops completed.
void	setConnectionConfig(HttpHost host, ConnectionConfig connectionConfig)
void	setDefaultConnectionConfig(ConnectionConfig defaultConnectionConfig)
void	setDefaultMaxPerRoute(int max)
void	setDefaultSocketConfig(SocketConfig defaultSocketConfig)
void	setMaxPerRoute(HttpRoute route, int max)
void	setMaxTotal(int max)
void	setSocketConfig(HttpHost host, SocketConfig socketConfig)
void	shutdown() Shuts down this connection manager and releases tlb resources.
void	upgrade(HttpClientConnection managedConn, HttpRoute route, HttpContext context) Upgrades the underlying connection socket to TLS/SSL (or another layering protocol) after having executed CONNECT method to all intermediate proxy hops

从类继承的方法 java.lang.Object

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

构造器详细资料

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager()

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager(long timeToLive,
                                  java.util.concurrent.TimeUnit tunit)

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry)

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry,
                                  DnsResolver dnsResolver)

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry,
                                  HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory)

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager(HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory)

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry,
                                  HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory,
                                  DnsResolver dnsResolver)

PoolingHttpClientConnectionManager

public PoolingHttpClientConnectionManager(Registry<ConnectionSocketFactory> socketFactoryRegistry,
                                  HttpConnectionFactory<HttpRoute,ManagedHttpClientConnection> connFactory,
                                  SchemePortResolver schemePortResolver,
                                  DnsResolver dnsResolver,
                                  long timeToLive,
                                  java.util.concurrent.TimeUnit tunit)

方法详细资料

finalize

protected void finalize()
                 throws java.lang.Throwable

覆盖:

finalize 在类中 java.lang.Object

抛出:

java.lang.Throwable

close

public void close()

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

requestConnection

public ConnectionRequest requestConnection(HttpRoute route,
                                  java.lang.Object state)

从接口复制的说明: HttpClientConnectionManager

Returns a new ConnectionRequest, from which a HttpClientConnection can be obtained or the request can be aborted.

Please note that newly tlb connections can be returned in the closed state. The consumer of that connection is responsible for fully establishing the route the to the connection target by calling connect in order to connect directly to the target or to the first proxy hop, optionally calling upgrade method to upgrade the connection after having executed CONNECT method to all intermediate proxy hops and and finally calling routeComplete to mark the route as fully completed.

指定者:

requestConnection 在接口中 HttpClientConnectionManager

参数:

route - HTTP route of the requested connection.

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

leaseConnection

protected HttpClientConnection leaseConnection(java.util.concurrent.Future<depends.org.apache.http.impl.conn.CPoolEntry> future,
                                   long timeout,
                                   java.util.concurrent.TimeUnit tunit)
                                        throws java.lang.InterruptedException,
                                               java.util.concurrent.ExecutionException,
                                               ConnectionPoolTimeoutException

抛出:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

ConnectionPoolTimeoutException

releaseConnection

public void releaseConnection(HttpClientConnection managedConn,
                     java.lang.Object state,
                     long keepalive,
                     java.util.concurrent.TimeUnit tunit)

从接口复制的说明: HttpClientConnectionManager

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

指定者:

releaseConnection 在接口中 HttpClientConnectionManager

参数:

managedConn - the managed connection to release.

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

tunit - the time unit.

另请参阅:

HttpClientConnectionManager.closeExpiredConnections()

connect

public void connect(HttpClientConnection managedConn,
           HttpRoute route,
           int connectTimeout,
           HttpContext context)
             throws java.io.IOException

从接口复制的说明: HttpClientConnectionManager

Connects the underlying connection socket to the 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).

指定者:

connect 在接口中 HttpClientConnectionManager

参数:

managedConn - the managed connection.

route - the route of the connection.

connectTimeout - connect timeout in milliseconds.

context - the actual HTTP context.

抛出:

java.io.IOException

upgrade

public void upgrade(HttpClientConnection managedConn,
           HttpRoute route,
           HttpContext context)
             throws java.io.IOException

从接口复制的说明: HttpClientConnectionManager

Upgrades the underlying connection socket to TLS/SSL (or another layering protocol) after having executed CONNECT method to all intermediate proxy hops

指定者:

upgrade 在接口中 HttpClientConnectionManager

参数:

managedConn - the managed connection.

route - the route of the connection.

context - the actual HTTP context.

抛出:

java.io.IOException

routeComplete

public void routeComplete(HttpClientConnection managedConn,
                 HttpRoute route,
                 HttpContext context)
                   throws java.io.IOException

从接口复制的说明: HttpClientConnectionManager

Marks the connection as fully established with all its intermediate hops completed.

指定者:

routeComplete 在接口中 HttpClientConnectionManager

参数:

managedConn - the managed connection.

route - the route of the connection.

context - the actual HTTP context.

抛出:

java.io.IOException

shutdown

public void shutdown()

从接口复制的说明: HttpClientConnectionManager

Shuts down this connection manager and releases tlb resources. This includes closing all connections, whether they are currently used or not.

指定者:

shutdown 在接口中 HttpClientConnectionManager

closeIdleConnections

public void closeIdleConnections(long idleTimeout,
                        java.util.concurrent.TimeUnit tunit)

从接口复制的说明: HttpClientConnectionManager

Closes idle connections in the pool.

Open connections in the pool that have not been used for the timespan given by the argument will be closed. Currently tlb connections are not subject to this method. Times will be checked with milliseconds precision All expired connections will also be closed.

指定者:

closeIdleConnections 在接口中 HttpClientConnectionManager

参数:

idleTimeout - the idle time of connections to be closed

tunit - the unit for the idletime

另请参阅:

HttpClientConnectionManager.closeExpiredConnections()

closeExpiredConnections

public void closeExpiredConnections()

从接口复制的说明: HttpClientConnectionManager

Closes all expired connections in the pool.

Open connections in the pool that have not been used for the timespan defined when the connection was released will be closed. Currently tlb connections are not subject to this method. Times will be checked with milliseconds precision.

指定者:

closeExpiredConnections 在接口中 HttpClientConnectionManager

getMaxTotal

public int getMaxTotal()

指定者:

getMaxTotal 在接口中 ConnPoolControl<HttpRoute>

setMaxTotal

public void setMaxTotal(int max)

指定者:

setMaxTotal 在接口中 ConnPoolControl<HttpRoute>

getDefaultMaxPerRoute

public int getDefaultMaxPerRoute()

指定者:

getDefaultMaxPerRoute 在接口中 ConnPoolControl<HttpRoute>

setDefaultMaxPerRoute

public void setDefaultMaxPerRoute(int max)

指定者:

setDefaultMaxPerRoute 在接口中 ConnPoolControl<HttpRoute>

getMaxPerRoute

public int getMaxPerRoute(HttpRoute route)

指定者:

getMaxPerRoute 在接口中 ConnPoolControl<HttpRoute>

setMaxPerRoute

public void setMaxPerRoute(HttpRoute route,
                  int max)

指定者:

setMaxPerRoute 在接口中 ConnPoolControl<HttpRoute>

getTotalStats

public PoolStats getTotalStats()

指定者:

getTotalStats 在接口中 ConnPoolControl<HttpRoute>

getStats

public PoolStats getStats(HttpRoute route)

指定者:

getStats 在接口中 ConnPoolControl<HttpRoute>

getDefaultSocketConfig

public SocketConfig getDefaultSocketConfig()

setDefaultSocketConfig

public void setDefaultSocketConfig(SocketConfig defaultSocketConfig)

getDefaultConnectionConfig

public ConnectionConfig getDefaultConnectionConfig()

setDefaultConnectionConfig

public void setDefaultConnectionConfig(ConnectionConfig defaultConnectionConfig)

getSocketConfig

public SocketConfig getSocketConfig(HttpHost host)

setSocketConfig

public void setSocketConfig(HttpHost host,
                   SocketConfig socketConfig)

getConnectionConfig

public ConnectionConfig getConnectionConfig(HttpHost host)

setConnectionConfig

public void setConnectionConfig(HttpHost host,
                       ConnectionConfig connectionConfig)