我正在尝试制作一个可以同时在多个终端之间共享的简单文本编辑器。我有一个等待新用户的服务器，当用户进入共享编辑器时，它就开始等待输入字符。

public class Server {
    public static final int PORT = 8080; 
    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(PORT);

        while (true) {
            Socket socket = ss.accept();
            System.out.println("A new user entered the sever");
            new Thread(() -> serve(socket)).start();
        }
    }

    private static void serve(Socket socket) {
        try {
            while (!socket.isClosed() && !socket.isInputShutdown()) {
                System.out.println("hey " + socket.isClosed() + " " + socket.isInputShutdown());
                System.out.print(new String(SocketUtil.receiveBytes(socket,1)));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

当用户关闭编辑器时，套接字在客户端关闭。但是，服务器端的套接字没有关闭，服务器开始在“等待输入”循环中无限循环。

Client 是一个包含以下方法的单例，在编辑器打开和关闭时调用。

public static void init() {
        try {
            if (socket == null) socket = new Socket(HOST,Server.PORT);
        } catch (IOException e) {
            e.printStackTrace();
            kill();
            throw new Error(e.getMessage());
        }
    }

    public static void kill() {
        Check.notNull(socket);
        try {
            SocketUtil.terminateCommunication(socket);
            System.out.println(socket.isClosed());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

最后，这是两个类中使用的实用方法(在 SocketUtil 中):

public static void terminateCommunication(Socket socket) throws IOException {
    socket.shutdownInput();
    socket.shutdownOutput();
    socket.close();
}

public static char[] receiveBytes(Socket socket, int nBytes) throws IOException {
    char[]            bytes = new char[nBytes];
    InputStreamReader isr   = new InputStreamReader(socket.getInputStream());
    isr.read(bytes);
    return bytes;
}

知道为什么 Client 被杀死后服务器端的套接字没有关闭吗？

最佳答案

Javadoc 不是很清楚，但是 isClosed() 仅在您明确调用 close() 时返回 true套接字(请参阅来源以确认)。您应该检查异常和 read() 的返回值。如果您在尝试读取(或写入)时读取到 -1 或捕获到 IOException，这实际上意味着另一端已关闭连接，因此您也应该关闭您的套接字(最好在 finally block 中关闭)并且您已完成该特定连接。您不会在 receiveBytes() 中检查 -1，但您确实应该这样做。如果你想将这两种可能性合并为一个，也许抛出一个 EOFException()，这样堆栈上的代码(在 serve() 中)就不必计算了到底发生了什么:

public static char[] receiveBytes(Socket socket, int nBytes) throws IOException {
    char[]            bytes = new char[nBytes];
    InputStreamReader isr   = new InputStreamReader(socket.getInputStream());
    if (isr.read(bytes) == -1)
        throw new EOFException();
    return bytes;
}

IOException 规则的一个异常(exception)(抱歉是双关语)是 SocketTimeoutException。如果你得到这个，连接仍然存在，你也可以重试你的 read()。但我相信，为了获得这些，您必须在某处调用 Socket.setSoTimeout()，如果没有，那么您可能不必担心 SocketTimeoutException .

您还应该注意 read() 有时可能会返回部分读取(即小于 bytes.length)。如果 receiveBytes() 准确读取 nBytes 很重要(这可能是因为您永远不会返回读取的实际字符数)，那么您应该在循环中调用它，像这样:

    int pos = 0;
    while (pos < bytes.length) {
        int l;
        if ((l = isr.read(bytes, pos, bytes.length - pos)) == -1) {
            throw new EOFException();
        }
        pos += l;
    }

我知道这很麻烦，这正是许多开发人员创建像您的 receiveBytes() 这样的实用方法的原因。

关于java - 为什么我的 Socket 没有在服务器端关闭？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30014460/