多线程服务器 - 如何正确处理客户端和服务器断开连接答案

【问题标题】：Multithreaded server- how to properly handle both client and server disconnect多线程服务器 - 如何正确处理客户端和服务器断开连接
【发布时间】：2016-02-20 13:17:58
【问题描述】：

我正在编写一个简单的多线程聊天服务器。每个客户端在连接时都在创建新线程

    Thread listenThread = new Thread(() -> {
        while (true) {
            try {
                Socket client = serverSocket.accept();
                ClientThread handler = new ClientThread(this, client);
                clients.add(handler);
                handler.start();
            } catch (SocketException e) {
                if (e.getMessage().contains("socket closed"))
                    break;

                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    });

此方法适用于检查客户端是否关闭连接。

class ClientThread extends Thread {
    @Override
    public void run() {
        while(running) {
            int read = inputStream.read();
            if(read > 0) {
                // read
            }
            else if(read < 0)
                running = false;        
        }
    }   
};

问题是，当我想停止服务器时，我无法中止线程，因为inputStream.read() 会阻止执行，因此将running 变量设置为false 无效。如何让它发挥作用？

【问题讨论】：

标签： java multithreading sockets network-programming

【解决方案1】：

如果您希望服务器立即退出，请将客户端线程设为守护线程。
如果您希望客户端线程干净地关闭其套接字，请在接受套接字上设置较短的读取超时，并让它们在每次超时时检查您的标志。

【讨论】：