1

这是发生问题的代码片段:

public static byte[] copyLargeExt(InputStream input) throws IOException {
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        byte[] buffer = new byte[1024*8];
        int n = 0;
        while(-1 != (n = input.read(buffer))) {
            baos.write(buffer, 0, n);
        // i just append this pattern ({###END###}) to force the break  
           /*if(baos.toString(UTF8.name()).endsWith("{###END###}")) {
                break;
            }*/
        }
        return baos.toByteArray();
    }

有人能帮我吗?

4

2 回答 2

2

问题中的代码读取到套接字流的末尾。如果方法是阻塞的并且在 read 调用中,那只能意味着另一端还没有关闭其对应的输出流。

你有两个选择:

  • 更改另一端以关闭其输出流,以便此代码将看到 EOF。

  • 更改“协议”,以便此代码知道预期的数据字节数......并准确读取该字节数。

于 2012-11-08T11:35:31.140 回答
2

在爪哇。
如果Server只Socket.close()没有OutputStream.close()first,Client的InputStream.read()就不会返回-1
相反,客户端InputStream.read()将阻塞直到超时。所以服务器上的最佳实践是:

OutputStream.close();
InputStream.close();
Socket.close();
于 2016-08-10T11:56:29.430 回答