java - 如何使用netty中的SimpleChannelPool在连接错误时关闭 channel ？

Question

我正在尝试在 netty 中使用连接池，但在编写一些错误处理时遇到问题。我的原始代码如下所示:

ChannelFuture connectFuture = bootstrap.connect(...);
connectFuture.addListener(ChannelFutureListener.CLOSE_ON_FAILURE);

但是，ChannelPool.acquire返回 Future<Channel> 。这意味着在操作失败时，无法访问该 channel ，因此我不知道关闭它的方法。关闭失败的 channel 重要吗？我认为它可能仍然占用一些系统资源，即使它无法连接。

我认为相关代码在netty类中SimpleChannelPool在notifyConnect :

    private void notifyConnect(ChannelFuture future, Promise<Channel> promise) throws Exception {
        if (future.isSuccess()) {
            Channel channel = future.channel();
            handler.channelAcquired(channel);
            if (!promise.trySuccess(channel)) {
                // Promise was completed in the meantime (like cancelled), just release the channel again
                release(channel);
            }
        } else {
            promise.tryFailure(future.cause());
        }
    }

在这里我们可以看到返回给调用者的promise失败了，但是 channel 没有传播。

Answer 1

这最终非常简单，您只需要重写 SimpleChannelPool.connectChannel()` 并在其中添加监听器即可。