1

我正在读取从套接字的服务器端接收的输入流。我无法知道我的响应的大小是多少，我正在读入一个字节数组，这是代码

public static String readString(InputStream inputStream) throws IOException {

    ByteArrayOutputStream into = new ByteArrayOutputStream();
    byte[] buf = new byte[4096];
    for (int n; 0 < (n = inputStream.read(buf));) {
        System.out.println("Got to this point n is "+n);
        into.write(buf, 0, n); 
    }
    into.close();
    System.out.println("passed this point");
    return new String(into.toByteArray(), AddATudeMessage.CHARENC); 
}

现在写数字 11 和 235 被打印到控制台，所以我假设服务器仍在将输出写入输入流。然而，它卡在 235 并且似乎没有发生任何事情。我尝试暂停主执行线程长达 20 秒，此时我从服务器收到 241 个字节，然后再次发生相同的无限循环，任何人都知道发生了什么

4

4 回答 4

3

您的代码的结构方式只有在服务器完成后关闭套接字时才能工作。否则，您的一方永远无法知道服务器是否已完成或仅仅是缓慢（或存在网络拥塞）。

解决这个问题只有两种方法：

  1. 让服务器先发送预期的长度，然后在收到指定的字节数时停止读取并继续。
  2. 让服务器在完成后发送一个特殊的数据序列，某种在正常数据中不会出现的 EOF 标记，您可以寻找它来告诉您何时没有更多数据。

使用的解决方案available()是不正确的，因为如果接收缓冲区当前为空但仍有数据在传输中，则它可以返回零。

于 2012-10-06T22:15:58.120 回答
0

inputStream.read(buf)在服务器关闭套接字（或者可能是元数据包的某些特殊情况或其他情况）之前，不会返回 0。

于 2012-10-06T19:49:23.173 回答
0

考虑使用int available()(InputStream)
它返回可以从此输入流读取（或跳过）的字节数，而不会被此输入流的方法的下一个调用者阻塞。

于 2012-10-06T19:54:15.360 回答
-1

方法 int InputStream.read() 阻塞，直到它从套接字接收到数据，接收到流序列的结尾或抛出异常。

考虑使用以下语句：

   for (; inputStream.available() > 0;)

在这种情况下，如果套接字上没有可用数据，则 for 循环结束并且您的程序可以继续。当然，你必须调整你的代码来做你想做的事情。

于 2012-10-06T20:12:26.567 回答