为 InputStreamreader 变量设置超时

Question

我有一个正在运行的服务器，它接受通过客户端套接字建立的连接，我需要从这个客户端套接字读取输入，现在假设客户端打开了与我的服务器的连接，而没有通过服务器的套接字输出流发送任何内容，在这种情况下，当我的服务器尝试通过客户端套接字的输入流读取输入时，将引发异常，但在引发异常之前我希望超时 5 秒，我该怎么做？目前这是我的代码在服务器端的样子：

try 
    {
        InputStreamReader clientInputStream = new InputStreamReader(clientSocket.getInputStream());
        int c;
        StringBuffer requestBuffer = new StringBuffer();
        while ((c = clientInputStream.read()) != -1) 
        { 
            requestBuffer.append((char) c);
            if (requestBuffer.toString().endsWith(("\r\n\r\n")))
                break;
        }
        request = new Request(requestBuffer.toString(), clientSocket);
    } 
    catch (Exception e) // catch any possible exception in order to keep the thread running
    {
        try 
        {
            if (clientSocket != null)
                clientSocket.close();
        } catch (IOException ex) 
        {
            ex.printStackTrace();
        }
        System.err.println(e);
        //e.printStackTrace();
    }

Answer 1

教科书的答案是在您的套接字上设置soTimeout，您可以这样做。但是，这并不适用于所有情况。我的一个朋友曾经通过拔出我的网线来证明这一点。我将 soTimeout 设置为 30 秒的值，但我的应用程序只是永远挂在那里。

要获得可靠的超时，最好将 I/O 分离到另一个线程上。如果线程在给定时间内没有返回响应，您可以尝试中断它，关闭流并最终销毁线程。这不会让你更进一步，但会尝试清理流。一旦发生超时，您将需要考虑当前通信丢失，重新建立连接并重新发送先前的命令以重复通信。 command-pattern 可以在这里提供帮助。如果命令是幂等的并且可以多次执行，则执行起来会容易得多。能够重复失败的请求可用于处理间歇性 I/O 错误。

Answer 2

您是否尝试过在底层套接字上设置超时？见Socket.setSoTimeout()。来自文档：

将此选项设置为非零 超时，read() 调用 与此关联的 InputStream 套接字将仅阻止此数量 的时间。如果超时到期，则 java.net.SocketTimeoutException 是 提出，虽然套接字仍然 有效