Java TCP客户端重复连接引发EMFILE错误，求排查与解决

首先，你的服务器抛出Errno::EMFILE Too many files open的核心原因是客户端每秒创建一个全新的TCP连接，短时间内会在服务器端积累大量处于TIME_WAIT状态的连接（默认TCP连接关闭后会保持这个状态60秒），耗尽了服务器的文件描述符配额（Mac系统默认单进程文件描述符上限通常是1024左右）。

再看你的客户端代码，每次调度任务执行时都会新建Socket、输入输出流，虽然最后调用了closeSocketPax，但频繁的连接创建/销毁不仅效率极低，还会给服务器带来巨大的资源压力。另外手动关闭资源的方式也存在潜在的泄漏风险（比如异常场景下某些流可能没被正确关闭）。

修复方案：改用长连接复用连接 #

最彻底的解决办法是复用一个TCP长连接，而不是每秒新建。下面是具体的代码修改：

1. 调整成员变量与连接初始化逻辑

首先在类中新增连接状态标记，把连接初始化逻辑抽成独立方法：

public class TestTCP extends JPanel {
    // 原有的成员变量...
    private boolean isConnected = false; // 新增：标记连接是否有效

    // 新增：建立/复用连接的方法
    private boolean establishConnection() {
        try {
            // 如果连接不存在或已关闭，重新建立
            if (socket == null || socket.isClosed()) {
                socket = new Socket("192.168.1.2", 7767);
                output = new DataOutputStream(socket.getOutputStream());
                br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                isConnected = true;
                System.out.println("成功建立TCP连接");
            }
            return true;
        } catch (IOException e) {
            System.out.println("连接建立失败: " + e.getMessage());
            closeSocketPax();
            isConnected = false;
            return false;
        }
    }

    // 原有的其他方法...
}

2. 修改通信逻辑，复用连接

重构communicateWithServer，去掉每次新建连接的逻辑：

public void communicateWithServer() {
    // 先确保连接有效，失败则直接结束任务
    if (!isConnected && !establishConnection()) {
        isMapUpdating = false;
        return;
    }

    String messageToServer = makeMessageToServer();
    String messageFromServer = "";
    String terminator = "END_IGOCONNECT_DATA";

    try {
        // 发送消息（记得flush确保数据立即发送）
        output.writeBytes(messageToServer);
        output.flush();
        System.out.println("发送给服务器的消息: " + messageToServer);

        // 读取响应
        StringBuilder sb = new StringBuilder();
        int value;
        while ((value = br.read()) != -1) {
            char c = (char) value;
            sb.append(c);
            if (sb.toString().contains(terminator)) {
                break;
            }
        }
        messageFromServer = sb.toString();

    } catch (IOException e) {
        System.out.println("通信出错: " + e.getMessage());
        // 连接异常时关闭现有连接，下次任务会自动重连
        closeSocketPax();
        isConnected = false;
        messageFromServer = "ERROR";
        // 这里可以保留你的弹窗提示逻辑
    } finally {
        isMapUpdating = false;
    }

    SwingUtilities.invokeLater(() -> {
        messageReceived(messageFromServer);
    });
}

3. 优化资源关闭逻辑（可选但推荐）

如果后续需要使用短连接场景，推荐用Java的try-with-resources语法自动管理资源，避免手动关闭遗漏：

// 示例短连接场景的通信实现
public String connectWithShortLivedSocket(String messageToServer) {
    String data = "";
    String terminator = "END_IGOCONNECT_DATA";

    // try-with-resources会自动关闭所有实现AutoCloseable的资源
    try (Socket socket = new Socket("192.168.1.2", 7767);
         DataOutputStream output = new DataOutputStream(socket.getOutputStream());
         BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {

        output.writeBytes(messageToServer);
        output.flush();
        System.out.println("发送给服务器的消息: "+messageToServer);

        StringBuilder sb = new StringBuilder();
        int value;
        while((value = br.read()) != -1) {
            char c = (char)value;
            sb.append(c);
            if(sb.toString().contains(terminator)) {
                break;
            }
        }
        data = sb.toString();

    } catch (UnknownHostException e) {
        // 异常处理逻辑...
    } catch (EOFException e) {
        // 异常处理逻辑...
    } catch (IOException e) {
        // 异常处理逻辑...
    }
    return data;
}

额外建议 #

1. 服务器端优化：确保服务器处理完客户端请求后，及时关闭对应的Socket和流，避免资源泄漏。
2. 系统参数调整（临时方案）：如果必须使用短连接，可以临时提高Mac的文件描述符限制（比如通过ulimit -n 4096命令），但这只是治标不治本的办法。

内容的提问来源于stack exchange，提问作者Igor Tupitsyn