io.netty.channel.pool

类 FixedChannelPool

java.lang.Object

io.netty.channel.pool.SimpleChannelPool

io.netty.channel.pool.FixedChannelPool

所有已实现的接口:

ChannelPool, java.io.Closeable, java.lang.AutoCloseable

public class FixedChannelPool
extends SimpleChannelPool

ChannelPool implementation that takes another ChannelPool implementation and enforce a maximum number of concurrent connections.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	FixedChannelPool.AcquireTimeoutAction

构造器概要

构造器

构造器和说明
FixedChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, ChannelHealthChecker healthCheck, FixedChannelPool.AcquireTimeoutAction action, long acquireTimeoutMillis, int maxConnections, int maxPendingAcquires) Creates a new instance.
FixedChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, ChannelHealthChecker healthCheck, FixedChannelPool.AcquireTimeoutAction action, long acquireTimeoutMillis, int maxConnections, int maxPendingAcquires, boolean releaseHealthCheck) Creates a new instance.
FixedChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, ChannelHealthChecker healthCheck, FixedChannelPool.AcquireTimeoutAction action, long acquireTimeoutMillis, int maxConnections, int maxPendingAcquires, boolean releaseHealthCheck, boolean lastRecentUsed) Creates a new instance.
FixedChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, int maxConnections) Creates a new instance using the ChannelHealthChecker.ACTIVE.
FixedChannelPool(Bootstrap bootstrap, ChannelPoolHandler handler, int maxConnections, int maxPendingAcquires) Creates a new instance using the ChannelHealthChecker.ACTIVE.

方法概要

方法

限定符和类型	方法和说明
Future<Channel>	acquire(Promise<Channel> promise) Acquire a Channel from this ChannelPool.
void	close()
Future<java.lang.Void>	release(Channel channel, Promise<java.lang.Void> promise) Release a Channel back to this ChannelPool.

从类继承的方法 io.netty.channel.pool.SimpleChannelPool

acquire, bootstrap, connectChannel, handler, healthChecker, offerChannel, pollChannel, release, releaseHealthCheck

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

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

构造器详细资料

FixedChannelPool

public FixedChannelPool(Bootstrap bootstrap,
                ChannelPoolHandler handler,
                int maxConnections)

Creates a new instance using the ChannelHealthChecker.ACTIVE.

参数:

bootstrap - the Bootstrap that is used for connections

handler - the ChannelPoolHandler that will be notified for the different pool actions

maxConnections - the number of maximal active connections, once this is reached new tries to acquire a Channel will be delayed until a connection is returned to the pool again.

FixedChannelPool

public FixedChannelPool(Bootstrap bootstrap,
                ChannelPoolHandler handler,
                int maxConnections,
                int maxPendingAcquires)

Creates a new instance using the ChannelHealthChecker.ACTIVE.

参数:

bootstrap - the Bootstrap that is used for connections

handler - the ChannelPoolHandler that will be notified for the different pool actions

maxConnections - the number of maximal active connections, once this is reached new tries to acquire a Channel will be delayed until a connection is returned to the pool again.

maxPendingAcquires - the maximum number of pending acquires. Once this is exceed acquire tries will be failed.

FixedChannelPool

public FixedChannelPool(Bootstrap bootstrap,
                ChannelPoolHandler handler,
                ChannelHealthChecker healthCheck,
                FixedChannelPool.AcquireTimeoutAction action,
                long acquireTimeoutMillis,
                int maxConnections,
                int maxPendingAcquires)

Creates a new instance.

参数:

bootstrap - the Bootstrap that is used for connections

handler - the ChannelPoolHandler that will be notified for the different pool actions

healthCheck - the ChannelHealthChecker that will be used to check if a Channel is still healthy when obtain from the ChannelPool

action - the FixedChannelPool.AcquireTimeoutAction to use or null if non should be used. In this case must be -1.

acquireTimeoutMillis - the time (in milliseconds) after which an pending acquire must complete or the FixedChannelPool.AcquireTimeoutAction takes place.

maxConnections - the number of maximal active connections, once this is reached new tries to acquire a Channel will be delayed until a connection is returned to the pool again.

maxPendingAcquires - the maximum number of pending acquires. Once this is exceed acquire tries will be failed.

FixedChannelPool

public FixedChannelPool(Bootstrap bootstrap,
                ChannelPoolHandler handler,
                ChannelHealthChecker healthCheck,
                FixedChannelPool.AcquireTimeoutAction action,
                long acquireTimeoutMillis,
                int maxConnections,
                int maxPendingAcquires,
                boolean releaseHealthCheck)

Creates a new instance.

参数:

bootstrap - the Bootstrap that is used for connections

handler - the ChannelPoolHandler that will be notified for the different pool actions

healthCheck - the ChannelHealthChecker that will be used to check if a Channel is still healthy when obtain from the ChannelPool

action - the FixedChannelPool.AcquireTimeoutAction to use or null if non should be used. In this case must be -1.

acquireTimeoutMillis - the time (in milliseconds) after which an pending acquire must complete or the FixedChannelPool.AcquireTimeoutAction takes place.

maxConnections - the number of maximal active connections, once this is reached new tries to acquire a Channel will be delayed until a connection is returned to the pool again.

maxPendingAcquires - the maximum number of pending acquires. Once this is exceed acquire tries will be failed.

releaseHealthCheck - will check channel health before offering back if this parameter set to true.

FixedChannelPool

public FixedChannelPool(Bootstrap bootstrap,
                ChannelPoolHandler handler,
                ChannelHealthChecker healthCheck,
                FixedChannelPool.AcquireTimeoutAction action,
                long acquireTimeoutMillis,
                int maxConnections,
                int maxPendingAcquires,
                boolean releaseHealthCheck,
                boolean lastRecentUsed)

Creates a new instance.

参数:

bootstrap - the Bootstrap that is used for connections

handler - the ChannelPoolHandler that will be notified for the different pool actions

healthCheck - the ChannelHealthChecker that will be used to check if a Channel is still healthy when obtain from the ChannelPool

action - the FixedChannelPool.AcquireTimeoutAction to use or null if non should be used. In this case must be -1.

acquireTimeoutMillis - the time (in milliseconds) after which an pending acquire must complete or the FixedChannelPool.AcquireTimeoutAction takes place.

maxConnections - the number of maximal active connections, once this is reached new tries to acquire a Channel will be delayed until a connection is returned to the pool again.

maxPendingAcquires - the maximum number of pending acquires. Once this is exceed acquire tries will be failed.

releaseHealthCheck - will check channel health before offering back if this parameter set to true.

lastRecentUsed - true Channel selection will be LIFO, if false FIFO.

方法详细资料

acquire

public Future<Channel> acquire(Promise<Channel> promise)

从接口复制的说明: ChannelPool

Acquire a Channel from this ChannelPool. The given Promise is notified once the acquire is successful and failed otherwise. Its important that an acquired is always released to the pool again, even if the Channel is explicitly closed..

指定者:

acquire 在接口中 ChannelPool

覆盖:

acquire 在类中 SimpleChannelPool

release

public Future<java.lang.Void> release(Channel channel,
                             Promise<java.lang.Void> promise)

从接口复制的说明: ChannelPool

Release a Channel back to this ChannelPool. The given Promise is notified once the release is successful and failed otherwise. When failed the Channel will automatically closed.

指定者:

release 在接口中 ChannelPool

覆盖:

release 在类中 SimpleChannelPool

close

public void close()

指定者:

close 在接口中 ChannelPool

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

覆盖:

close 在类中 SimpleChannelPool