InputStream 读取源中不存在的额外字节

Question

我有接收从客户端应用程序发送的 RTMP 数据包的 Java 服务器。服务器使用InputStream 读取packet header，识别packet body 的大小，然后使用size 创建byte array，然后从InputStream 中的array 中读取body。问题是：接收到的字节集被修改 - 有必要的字节（存在于源中）与额外的字节在源中不存在数据包（我通过 WireShark 观察源数据包的内容，并将它们与我在服务器上收到的字节进行比较）。
这些额外的字节是 0xc6 字节，顺便说一下定期会面...
它看起来像这样：
Source: ... 75 f1 f5 55 73 .... fc a9 47 14 ... 40 ca d5 75 ... fe 30 a7
Received: ... 75 f1 f5 55 73 c6 .... fc a9 47 14 c6 ... 40 ca d5 75 c6 ... fe 30 a7
... - 表示“这里有一些字节数”
结果，我无法接收到必要的数据，因为它被拉伸了，比我从 rtmp header 收到的 body size 大。最重要的是，修改后的数据不是我必须收到的！
我的问题是：如何修复？ InputStream 怎么了？为什么它将那些 0xc6 字节插入接收数组？
我知道我可以简单地解析接收到的数组并排除那些额外的字节，但这是一个糟糕的解决方案，因为速度和性能是必需的（并且，在这种情况下，不清楚它是来自源的额外字节或字节，没有比较整个数组）...

enter code here
public static void getRtmpPacket(InputStream in) throws Exception {

    byte[] rtmpHeader = new byte[8];
    byte[] rtmpBody;
    int bodySize = 0;

    //reading rtmp header:
    in.read(rtmpHeader);
    //reading the body size. This method works fine
    bodySize = Server.bigEndianBytesToInt(rtmpHeader, 4, 3);
    rtmpBody = new byte[bodySize];
    in.read(rtmpBody);
    //printing received data:
    System.out.println("Packet:");
    System.out.println("Body size: " + bodySize);
    System.out.print(bytesToString(rtmpHeader) + " ");
    System.out.print(bytesToString(rtmpBody));
    System.out.println();

}

Answer 1

根据 RTMP 规范，它的行为正常。您需要对传入的数据进行“分解”，因此在一次 read() 中一次读取所有数据是行不通的。

类似的东西（伪代码）：

int remaining = payloadSize;
int totalRead = 0;
int totalReadForChunk = 0;
while (true) {
  int num = read(buf, 0, min(remaining, chunkSize - totalReadForChunk))
  if (num < 0) break;  // i/o error
  appendData(<buf>, 0, num)
  totalReadForChunk += num
  remaining -= num
  if (remaining == 0) break;  // end of payload

  if (totalReadForChunk == chunkSize) {
     totalReadForChunk = 0;
     // read the chunk header (it's not neccessarily 0xc6)
     int header = read()
     if (header != currentStreamEmptyHeader) {  // 0xc6
       // ... parse the new rtmp message according to header value
       // (usually invoke the upper-level message reading method "recursively")
     }
  }
}

Answer 2

您可能应该看到（并使用）Red5 Media Server 的代码和其他实现 RTMP 协议的开源解决方案。

Answer 3

InputStream.read(byte[]) 只保证读取一个字节，它返回长度为实际读取长度的int。

in.read(rtmpHeader); // might read 1, 2, 3, .. 8 bytes.
//reading the body size. This method works fine
bodySize = Server.bigEndianBytesToInt(rtmpHeader, 4, 3);
rtmpBody = new byte[bodySize];
in.read(rtmpBody); // might read 1, 2, 3, ... bodySize bytes.

如果您不检查实际长度，并假设 byte[] 已满，则在调用 read() 之前您会得到任何字节。

使用 DataInputStream 可以获得您想要的内容

DataInputStream dis = new DataInputStream(in);

int len = dis.readInt(); // read an int in big endian.
byte[]] bytes = new byte[len];
dis.readFully(bytes); // read the whole byte[] or throw an IOException.

Answer 4

问题已解决。
那些额外的0xc6字节是RTMP数据包的分块字节，从WireShark看不到。
不仅如此，收到的 header 说的是实际的 body 大小，WireShark 会“确认”它，但实际上 body 的大小会更大，应该计算一下。

• https://www.wireshark.org/lists/wireshark-bugs/200801/msg00011.html
• http://red5.osflash.narkive.com/LYumrzr4/rtmp-video-packets-and-streaming-thereof#post12