Java：Socket关闭连接和ObjectInputStream

Question

我的代码看起来像这样，这是服务器代码（Runnable）

public void run() {
    while (true) {
        try {
            System.out.println("Waiting for client...");
            this.socket = serverSocket.accept();
            System.out.println("Client accepted");
            while (true) {
                readCommand();
                try {
                    Thread.sleep(2);
                } catch (Exception e) {
                }
            }
        } catch (Exception ex) {
            Main.error("Server stopped for current host", ex);
        }
    }
}

我的问题是：当客户端关闭连接时，他仍在等待读取readCommand();中的命令直到发送命令并抛出EOFException。这是我的 readCommand 方法：

private void readCommand() throws Exception {
    Object o = new ObjectInputStream(socket.getInputStream()).readObject();
    if (o instanceof Command) {
        ((Command) o).execute();
        return;
    }
    if (o instanceof Recorder) {
        System.out.println("Recording received");
        ((Recorder) o).executeRecord();
        return;
    }
    if (o instanceof MyKeyEvent) {
        ((MyKeyEvent) o).execute();
        return;
    }
}

所以我认为在读取之前必须检查连接是否打开。

编辑：如果我评估run方法代码，EOFException将在try-catch-body中抛出。但他停止接受客户。

Answer 1

如果客户端关闭连接，EOFException 正是我所期望的。所以我不太确定您的问题实际上是什么。。也许您需要区分预期的客户端断开连接和意外的客户端断开连接。在这种情况下，您也许应该发送某种 End-of-message 对象来标记传输结束？

如果您想检查信息是否可用，可以使用 available() 方法。顺便说一句，我认为您不需要 Thread.sleep(2) ，因为我希望在没有数据的情况下对 valid 输入流的读取会挂起。

Answer 2

您还可以“仅”添加另一个 try-catch 来捕获 EOFException

public void run() {
    while (true) {
        try {
            System.out.println("Waiting for client...");
            this.socket = serverSocket.accept();
            System.out.println("Client accepted");
            try {
                while (true) {
                    readCommand();
                    try {
                        Thread.sleep(2);
                    } catch (Exception e) {
                    }
                }
            } catch (EOFException ex) {
                System.out.println("client closed");
            }
        } catch (Exception ex) {
            Main.error("Server stopped for current host", ex);
        }
    }
}

当然，命令结束更加智能/优雅......
[]]