下面的程序充当 TCP 客户端并使用 NIO 打开到远程服务器的套接字，如下所示

private Selector itsSelector;
private SocketChannel itsChannel;

public boolean getConnection(Selector selector, String host, int port)
{
    try
    {
        itsSelector = selector;
        itsChannel = SocketChannel.open();
        itsChannel.configureBlocking(false);
        itsChannel.register(itsSelector, SelectionKey.OP_CONNECT);
        itsChannel.connect(new InetSocketAddress(host, port));
        if (itsChannel.isConnectionPending())
        {
            while (!itsChannel.finishConnect())
            {
                // waiting until connection is finished
            }
        }
        itsChannel.register(itsSelector, SelectionKey.OP_WRITE);
        return (itsChannel != null);
    }
    catch (IOException ex)
    {
        close();
        if(ex instanceof ConnectException)
        {
            LOGGER.log(Level.WARNING, "The remoteserver cannot be reached");
        }
    }
}

public void close()
{
    try
    {
        if (itsChannel != null)
        {
            itsChannel.close();
            itsChannel.socket().close();
            itsSelector.selectNow();
        }
}   
    catch (IOException e)
    {
        LOGGER.log(Level.WARNING, "Connection cannot be closed");
    }
}

此程序在 Red Hat Enterprise Linux Server 6.2 版(圣地亚哥)上运行 当并发套接字数量处于建立阶段时，文件描述符限制达到最大值，我在尝试建立更多套接字连接时看到以下异常。

java.net.SocketException: Too many open files
               at java.net.PlainSocketImpl.socketAccept(Native Method)
               at java.net.PlainSocketImpl.accept(PlainSocketImpl.java:408)

只有当远程节点关闭时才会发生这种情况，而当它启动时，一切都很好。 当远程 TCP 服务器关闭时，将抛出以下异常，如上面代码中的 IOException 处理

java.net.ConnectException: Connection refused: no further information
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)

在这种情况下，有什么办法可以强行关闭底层文件描述符。 预先感谢您提供的所有帮助。

最佳答案

private Selector itsSelector;

我看不出这个声明的意义所在。如果需要，您始终可以获得 channel 注册的选择器，但您永远不会这样做。可能您正在泄漏选择器？

itsChannel.configureBlocking(false);
itsChannel.register(itsSelector, SelectionKey.OP_CONNECT);

在这里，您正在注册 OP_CONNECT，但从未使用过该设施。

itsChannel.connect(new InetSocketAddress(host, port));

此处您正在启动一个挂起的连接。

if (itsChannel.isConnectionPending())

是的。你才刚刚开始。测试毫无意义。

{
    while (!itsChannel.finishConnect())
    {
        // waiting until connection is finished
    }
}

这完全是浪费时间和空间。如果您不想使用选择器检测 OP_CONNECT 何时触发，您应该调用 connect() before 将 channel 设置为非阻塞，并摆脱这种无意义的测试和循环。

    itsChannel.register(itsSelector, SelectionKey.OP_WRITE);
    return (itsChannel != null);

itsChannel 此时不可能为空。考试毫无意义。您最好允许可能出现的 IOExceptions 传播出此方法，以便调用者可以了解故障模式。这也让调用者有责任关闭任何异常，而不仅仅是您在此处捕获的异常。

catch (IOException ex)
{
    close();
    if(ex instanceof ConnectException)
    {
        LOGGER.log(Level.WARNING, "The remoteserver cannot be reached");
    }
}

见上文。删除所有这些。如果您想将 ConnectException 与其他 IOExceptions 区分开来，请分别捕获 它。而且您忘记记录任何不是 ConnectException 的内容。

public void close()
{
    try
    {
        if (itsChannel != null)
        {
            itsChannel.close();
            itsChannel.socket().close();
            itsSelector.selectNow();

第二次 close() 调用没有意义，因为 channel 已经关闭。

catch (IOException e)
{
    LOGGER.log(Level.WARNING, "Connection cannot be closed");
}

我很高兴看到您终于记录了一个 IOException，但您不太可能在这里得到任何信息。

不要这样写代码。

关于仅当远程 TCP 服务器关闭时，Java NIO 客户端才会导致文件描述符泄漏，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35838394/