android - 连接到 LocalServerSocket 时出现 EMFILE(打开的文件过多)错误？

Question

我的应用非常简单。客户端将连接到 LocalServerSocket(Unix 域套接字)并发送一些数据并断开连接。如果这个过程重复超过 1024 次，服务器在接受新客户端时抛出 java.io.IOException: socket failed: EMFILE (Too many open files)。

我已经在这里上传了我的演示代码 http://speedy.sh/NBSjr/SocketIssue.zip

您可以在代码中看到客户端在与服务器建立另一个连接之前关闭了建立的连接。在 logcat 中，您可以看到服务器中的 FileDescriptor 计数在增加，并在客户端第 1023 次连接时崩溃。

如何解决这个问题？请指教

我在运行 Android 4.3 的三星 S4 上试过。它似乎在重用文件描述符，我的演示应用程序可以运行数小时!

更新于 2014-05-19

如果您没有运行 Android 4.4.2 的设备，您可以在运行 Android 4.4.2 的模拟器上尝试此代码

Answer 1

我花了一些时间来运行你的代码，并用 e.printStack(); 填充所有的 try-catch block ，看看是否有一些异常被忽略，但运气不好，我可以'得到相同的IOException，它已经运行了1个多小时没有异常。

我有一个问题可能会有所帮助，那就是我找不到任何代码来计算 FileDescriptor ，也许你没有上传正确版本的代码，或者，你误会了log 05-18 05:18:50.409: V/SocketCmdServer(636): Incoming client fd:FileDescriptor[35] 中 FileDescriptor 的数量，我读到FileDescriptor的toString()源码，这个数字不是计数器而是fd类型。

/**
* The Unix file descriptor backing this FileDescriptor.
* A value of -1 indicates that this FileDescriptor is invalid.
*/
private int descriptor = -1;

@Override public String toString() {
    return "FileDescriptor[" + descriptor + "]";
}

在 Linux 上运行的任何 java vms 都可能有最大套接字连接数，因为 linux 将套接字连接作为一个文件，你可以通过这些 linux cmd 查看最大数量:

cat /proc/sys/fs/file-max

(PS:您可能需要一个 busybox 才能在 android 中获得完整的 linux cmd)

不建议修改最大文件数。

最重要的是，我有如下建议:
1)尽量避免达到系统设置的最大socket连接数限制
2) 填充所有的 try-catch block 来打印 track stack 以查看是否成功关闭套接字

 private void connectToServer() {
        LocalSocket client = null;
        ObjectOutputStream oos = null;
        ObjectInputStream ois  = null;
        try {
            client = new LocalSocket();

            Log.v(TAG, "connectToServer # Connect to the server");
            client.connect(new LocalSocketAddress(SOCKER_SERVER_NAME));

            Log.v(TAG, "connectToServer # Send the command");
            oos = new ObjectOutputStream(client.getOutputStream());
            oos.writeObject(new String("Hello"));
            oos.flush();

            ois = new ObjectInputStream(client.getInputStream());
            Object obj = ois.readObject();

            Log.v(TAG, "connectToServer # Response is received");
        }
        catch (Exception e) {
                Log.e(TAG, "connectToServer # Error:..", e);
        }
        finally {

            // each close() method should be wrapped in seperated try-catch block
            // or 1 or 2 close() method will be skipped
            try {
                if (oos != null) {
                    oos.close();
                    oos = null;
                }
                if (ois != null) {
                    ois.close();
                    ois = null;
                }

                if(client != null) {
                    client.close();
                    client = null;
                }
            }
            catch (IOException e) { 
                e.printStackTrace();
            }
        }
    }