套接字和数据输入流

Question

我试图理解这段代码

        DataInputStream stream = 
          new DataInputStream(
            new ByteArrayInputStream(messageBuffer));


        int     messageLength   = stream.readInt();
        char    recordType      = (char) stream.readByte();
        byte    padding         = stream.readByte();
        short   numberRecords   = stream.readShort();

messageBuffer 被初始化为新字节[32768]，通过 Socket.read() 方法填充。 我不明白的是，一旦 messageLength 被初始化为stream.readInt()，第二条语句将如何工作，即recordType？

第一个语句不会从字节数组的开头读取一个 int ，而下一个语句不会从字节数组的开头读取一个字节吗？它到底如何知道从哪个点读取字节、整数、短整型等？

Answer 1

来自文档：

ByteArrayInputStream 包含一个包含字节的内部缓冲区
可以从流中读取。 内部计数器跟踪
read 方法提供的下一个字节。

换句话说，DataInputStream 只是从 ByteArrayInputStream 读取，而后者记住字节数组中的当前位置，并在每次读取某些数据时前进。

Answer 2

readX() 不会从流的开头读取。事实上，术语流用于表示随着时间的推移而可用的数据序列。这意味着从流中的后续读取将检索不同的元素。

将流视为信息传送带而不是数组。

Answer 3

DataInputStream.read* 方法消耗底层输入流中的字节。在这种情况下，read* 方法读取 ByteArrayInputStream 提供的下一个可用字节，该字节将跟踪数组中的当前位置。

---

作为旁注，您可能需要考虑使用 ByteBuffer.wrap 和各种 ByteBuffer.read 方法：

ByteBuffer msgBuf = ByteBuffer.wrap(messageBuffer);
int messageLength = msgBuf.getInt();
char recordType   = msgBuf.getChar();
...

Answer 4

Socket.read() 将读取可用的字节。最小为一字节！最大值是缓冲区大小，其中可以包含任意数量的消息。

使用 DataInputStream/BufferedInputStream 比手动读取缓冲区更安全、更简单、更高效。

// create an input stream once per socket.
DataInputStream stream = 
      new DataInputStream(
        new BufferedInputStream(socket.getInputStream()));


int     messageLength   = stream.readInt();
char    recordType      = (char) stream.readByte();
byte    padding         = stream.readByte();
short   numberRecords   = stream.readShort();