1

我想BufferedInputStream istream从Socket. 数据首先包含一个字节n（8 位无符号整数），然后n是包含实际消息的字节（二进制格式，而不是字符串）。所以我写了以下代码（未测试）：

public byte[] getNextMessageBytes() throws IOException {
    // Make sure the "length" byte is ready to be read
    if (this.istream.available() < 1) {
        return null;
    }

    // Peek 1 byte
    this.istream.mark(1);
    int length = this.istream.read();

    // -1 == EOF
    if (length < 0) {
        throw new EOFException();
    }

    // reset the marked byte
    this.istream.reset();

    // If all bytes available...
    // NOTE the 'length' byte is still in the stream
    if (this.istream.available() > length) {

        // Peek the bytes...
        this.istream.mark(length + 1);
        // Skips the 'length' byte
        this.istream.skip(1);

        byte[] data = new byte[length];
        int recv = this.istream.read(data, 0, length);
        if (recv == length) {
            this.istream.mark(0);
            return data;
        }
        // -1 == EOF
        if (recv < 0) {
            throw new EOFException();
        }
        this.istream.reset();
    }
    return null;
}

这段代码基本上是先读取长度n字节。然后如果istream.available()指示可用的全长，它将尝试读取一定数量的字节，如果成功，则返回字节数组。

的文档BufferedInputStream.available()：

返回可以从此输入流中读取（或跳过）的字节数的估计值，而不会被下一次调用此输入流的方法阻塞。下一次调用可能是同一个线程或另一个线程。单次读取或跳过这么多字节不会阻塞，但可能会读取或跳过更少的字节。

“可以不阻塞地读取的字节”可以解释为“套接字已经接收到的字节”吗？实际上会istream.available()返回比已经接收到的数据少的数字（即一些尚未发送到缓冲区的数据）？

或者启动一个线程来继续阻塞读取并将消息推送到队列/列表/向量/数组列表/其他任何东西实际上是一个更好的主意吗？（需要同步）

我的应用程序需要是实时的（充其量，但毫秒级的延迟作为娱乐程序基本上是可以接受的），所以我很担心。该程序大多不完整，所以我还不能尝试。

4

1 回答 1

0

“可以不阻塞地读取的字节”可以解释为“套接字已经接收到的字节”吗？

那是它可以被解释的唯一方式。

istream.available() 实际上会返回比已经接收到的数据更少的数字（即一些尚未发送到缓冲区的数据）吗？

即使是待处理的数据，它也可以返回从零开始的任何内容。在 SSLSockets 上，它总是返回零。

但是，您不需要调用它，也不需要所有复杂的代码。只需在阻塞模式下读取流，并使用多个线程。

于 2013-01-31T23:13:46.813 回答