构造方法详细信息

• SimpleChannelPool

  public SimpleChannelPool(Bootstrap bootstrap,
                           ChannelPoolHandler handler)

  使用 ChannelHealthChecker.ACTIVE创建一个新实例。

  参数

  bootstrap - 用于连接的Bootstrap

  handler - 将通知不同池操作的ChannelPoolHandler

• SimpleChannelPool

  public SimpleChannelPool(Bootstrap bootstrap,
                           ChannelPoolHandler handler,
                           ChannelHealthChecker healthCheck)

  创建一个新的实例。

  参数

  bootstrap - 用于连接的Bootstrap

  handler - 将通知不同池操作的ChannelPoolHandler

  healthCheck -该ChannelHealthChecker将用来检查一个Channel时从获得仍然是健康ChannelPool

• SimpleChannelPool

  public SimpleChannelPool(Bootstrap bootstrap,
                           ChannelPoolHandler handler,
                           ChannelHealthChecker healthCheck,
                           boolean releaseHealthCheck)

  创建一个新的实例。

  参数

  bootstrap - 用于连接的Bootstrap

  handler - 将通知不同池操作的ChannelPoolHandler

  healthCheck - ChannelHealthChecker将用于检查从ChannelPool获得的Channel是否仍然健康

  releaseHealthCheck - 如果此参数设置为true ，则会在返回之前检查渠道健康状况; 否则，只有在采集时检查信道健康状况

• SimpleChannelPool

  public SimpleChannelPool(Bootstrap bootstrap,
                           ChannelPoolHandler handler,
                           ChannelHealthChecker healthCheck,
                           boolean releaseHealthCheck,
                           boolean lastRecentUsed)

  创建一个新的实例。

  参数

  bootstrap - 用于连接的Bootstrap

  handler - 将通知不同池操作的ChannelPoolHandler

  healthCheck -该ChannelHealthChecker将用来检查一个Channel时从获得仍然是健康ChannelPool

  releaseHealthCheck - 如果此参数设置为true ，则会在返回之前检查渠道健康状况; 否则，只有在采集时检查信道健康状况

  lastRecentUsed - true Channel选择将是LIFO，如果是false FIFO。

方法详细信息

• bootstrap

  protected Bootstrap bootstrap()

  返回该池将用于打开新连接的Bootstrap 。

  结果

  Bootstrap该池将用于打开新的连接

• handler

  protected ChannelPoolHandler handler()

  返回将通知不同池操作的ChannelPoolHandler 。

  结果

  ChannelPoolHandler将通知不同池操作

• healthChecker

  protected ChannelHealthChecker healthChecker()

  返回ChannelHealthChecker将用来检查一个Channel是健康的。

  结果

  该ChannelHealthChecker将被用来检查一个Channel是健康的

• releaseHealthCheck

  protected boolean releaseHealthCheck()

  指示此池在提供给池后是否会检查通道的健康状况。

  结果

  true如果此池在将它们提供回池中之前将检查通道的健康状况，或者 false如果只在采集时检查通道健康状况

• acquire

  public final Future<Channel> acquire()

  从接口ChannelPool复制的描述
  获得Channel从这个ChannelPool 。 一旦获得成功，通知返回的Future ，否则失败。 重要的是，即使Channel明确关闭，获得的数据也会再次发布到池中。

  Specified by:

  acquire在界面 ChannelPool

• acquire

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

  从接口ChannelPool复制的描述
  获得Channel从这个ChannelPool 。 一旦获得成功，通知给定的Promise ，否则失败。 重要的是，即使Channel明确关闭，获得的数据也会再次发布到池中。

  Specified by:

  acquire在界面 ChannelPool

• connectChannel

  protected ChannelFuture connectChannel(Bootstrap bs)

  引导一个新的Channel 。 默认实现使用Bootstrap.connect() ，子类可能会覆盖此。

  这里传递的Bootstrap是通过Bootstrap.clone()克隆的，所以修改是安全的。

• release

  public final Future<java.lang.Void> release(Channel channel)

  从接口ChannelPool复制的描述
  释放一个Channel回到这个ChannelPool 。 一旦发布成功，通知返回的Future ，否则失败。 失败时， Channel将自动关闭。

  Specified by:

  release在界面 ChannelPool

• release

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

  从接口ChannelPool复制的描述
  释放一个Channel回到这个ChannelPool 。 一旦发布成功，通知给定的Promise ，否则失败。 失败时， Channel将自动关闭。

  Specified by:

  release在界面 ChannelPool

• pollChannel

  protected Channel pollChannel()

  从内部存储中查询Channel以重新使用它。 如果没有Channel准备重新使用，这将返回null 。 子类可以覆盖pollChannel()和offerChannel(Channel) 。 请注意，这些方法的实现需要线程安全！

• offerChannel

  protected boolean offerChannel(Channel channel)

  提供Channel回到内部存储。 这将返回true如果Channel可以添加， false其他。 子类可能会覆盖pollChannel()和offerChannel(Channel) 。 请注意，这些方法的实现需要线程安全！

• close

  public void close()

  Specified by:

  close在界面 ChannelPool

  Specified by:

  close在界面 java.io.Closeable

  Specified by:

  close在界面 java.lang.AutoCloseable