(int a = DataInputStream.read(b, off, len)) 多次小于 (len)

Question

我在计算机上有服务器，它是客户端（Android 应用程序）。客户端向服务器发送一个大文件（2934822 字节）。这是客户端的代码：

this.socket_out = this.socket.getOutputStream();

ByteArrayOutputStream mByteArrayOutputStream = new ByteArrayOutputStream();
FileInputStream mFileInputStream = new FileInputStream(mFile);
while (true) {
    byte[] i1 = new byte[65536];
    int i2 = mFileInputStream.read(i1, 0, 65536);
    Log.v("", "read=" + i2);
    if (i2 < 0) {
        mByteArrayOutputStream.close();
        mFileInputStream.close();
        break;
    } else {
        mByteArrayOutputStream.write(i1, 0, i2);
        mByteArrayOutputStream.flush();
    }
}
mFile.delete();
byte[] i1 = mByteArrayOutputStream.toByteArray();
Log.v("", "sent=" + i1.length);
this.socket_out.write(i1);
this.socket_out.flush();

还有日志：

读取=65536

读取=65536

...

读取=65536

读取=51238

发送=2934822

这是服务器代码：

this.in = new DataInputStream(this.socket.getInputStream());

while (
    byte[] i1 = new byte[65536];
    int i2 = this.in.read(i1, 0, 65536);
    if (i2 > -1) {
        System.out.print(i2);
        ...
    } else {
        break;
    }
}

标准输出：

12974 1440 1440 11520 1440 1440 1440 7200 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 11520 1440 1440 59040 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 1440 17280 ...

为什么DataInputStream 没有完全读取 65536 字节？我怎样才能让它读取字节数组b 我在DataInputStream.read(byte[] b, int off, int len) 中的参数len 中设置的最大计数？谢谢。

Answer 1

为什么 DataInputStream 没有完全读取 65536 字节？

因为read()，或Socket，或TCP的合同中没有任何内容说它应该这样做。

如何让它读取我在 DataInputStream.read(byte[] b, int off, int len) 的参数 len 中设置的字节数组 b 的最大计数？

如果必须，请使用DataInputStream.readFully()，但这没有任何意义，就像在发送端使用ByteArrayOutputStream 浪费时间和空间一样。 Java中复制流的标准方法如下：

int count;
while ((count = in.read(buffer)) > 0)
{
    out.write(buffer, 0, count);
}

您应该在两端都使用此代码。

Answer 2

这可能是因为网络 MTU 大小。在DataInputStream 周围使用BufferedInputStream。

new BufferedInputStream(new DataInputStream(...

或者只是将DataInputStream替换为BufferedInputStream。或者在(new DataInputStream(new BufferedInputStream( ) 周围做相反的事情。这是装饰器模式。

Answer 3

数据不会神奇地出现在缓冲区中。传输实际上需要时间，并且您的程序执行速度比传输大文件要快。 while 循环每次都会抓取缓冲区中当前可用的内容，即您打印的这些字节数。你可以检查使用

int availableBytes = in.available();

您可以等待而不读取流，直到流中有一定数量的字节可供读取，例如

while(in.available() <2000)
{}

但这是一种阻塞方法，它将冻结您的服务器，直到字节到达。无论出于何种原因，它都会永远阻塞。

你也应该像这样初始化你的缓冲区

byte[] i1 = new byte[in.available()];

这样您就不会初始化比实际需要更多的资源，并且可以像这样读取

in.read(i1);

没有通过 if 语句的持续检查，并且确切地知道数据量是

i1.length

希望有帮助