Java DataInputStream 读取不返回

Question

我正在实现一个简单的客户端/服务器读取器，我正在使用 DataInputStream 将所有内容读取为字节，然后再进行解析。

这是我的阅读代码：

String line;
String requestString = "";

//client is a Socket that is initialized elsewhere
DataInputStream inputData = new DataInputStream(client.getInputStream());
byte [] messageByte = new byte[1024];
int counter = 0;
  while(true) {  
    int bytesRead = inputData.read(messageByte, counter, 1024-counter);
    counter = (counter + bytesRead)%1024;
    if(bytesRead == -1) {
      System.out.println("Breaking out of loop");
      break;
    }
    line = new String(messageByte, 0, bytesRead);
    System.out.println( "GOT > " + line );
  }

它可以读取消息，但不能跳出循环，因为最后一次调用 read 没有返回。

Answer 1

套接字将阻塞，直到没有更多输入。 InputStream 只是一个接口，具体行为取决于它的提供者实现。在您的套接字上设置超时，以便在特定时间段内没有输入时抛出异常。

这是来自javadoc on Socket 的引用，注意它将从套接字读取的行为描述为阻塞操作，直到达到超时：

public void setSoTimeout(int timeout)
                  throws SocketException

使用指定的超时时间启用/禁用SO_TIMEOUT，以毫秒为单位。将此选项设置为 非零超时，对与关联的 InputStream 的 read() 调用 这个 Socket 只会阻塞这段时间。如果超时 过期，引发 java.net.SocketTimeoutException，尽管 套接字仍然有效。必须在输入之前启用该选项 阻塞操作生效。超时时间必须 > 0。A 零超时被解释为无限超时。

解决办法：

除了检查 -1 之外还可以。在套接字上设置超时，并确保正确处理抛出的异常。