DataInputStream 的 readFully 查询

Question

我使用 dataInputStream 的 readFully 消息来读取固定长度的字节数组，如下所示：

byte[] record = new byte[4660004];

in.readFully(record);

这里的问题是，有时读取这么多字节需要 5 秒以上，相当于 20000 条记录。我正在套接字上接收这些数据。客户端以 4660004 字节的字节数组形式发送数据。有没有办法更快地接收这些数据，因为目前大约需要 5 分钟才能接收 100 万条此类记录。

编辑:: 完整的数据流：

首先我创建流：

static DataInputStream dIn = null;

dIn = new DataInputStream(connection.getInputStream());
msgType = dIn.readByte();

int msgIntLen = dIn.readInt();

processBatch(msgIntType, msgIntLen, dIn, connector);

.
.

private static void processBatch(int msgIntType, int msgIntLen, DataInputStream in,
            Connector connector) throws IOException {

   int recordIntLen = in.readInt();
   byte[] record = new byte[msgIntLen - 4];
   in.readFully(record);

}   

如果 wudf 有帮助，我应该在哪里包含缓冲？

Answer 1

评论开始滚动，所以转向答案。

使用 BufferedOutputStream 在客户端缓冲输出。确保在写入数据后调用 dlOut.flush() ，以便未发送的字节不会保留在缓冲的输出流中。

使用 BufferedInputStream 在客户端缓冲输入。

因为您只是发送字节数组，所以您可能不需要 DataInputStream/DataOuputStream，除非您将它们用于其他目的。您可以只使用 BufferedInputStream/BufferedOutputStream。