InputStream liest zusätzliche Bytes, die in Quelle nicht vorhanden sind

Question

Ich habe den Java-Server, der die RTMP-Pakete empfängt, die von der Client-App gesendet werden. Der Server liest die packet header mit InputStream, erkennt, wie groß die packet body ist, erstellt dann byte array mit der size und liest dann die body von InputStream in der .
Das Problem ist: der empfangene Satz von Bytes sind geändert - es gibt notwendige Bytes (die in der Quelle existieren) stehen mit zusätzlichen Bytes, die nicht im Quellpaket existieren (ich beobachte den Inhalt des Quellpakets über WireShark und vergleichen Sie sie mit den Bytes, die ich auf dem Server erhalten habe).
Diese zusätzlichen Bytes 0xc6 Bytes sind, die periodisch von der Art und Weise treffen ...
Es sieht wie folgt aus:
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
... - bedeutet "eine gewisse Menge von Bytes hier"
Als Ergebnis Ich kann keine notwendigen Daten empfangen, weil es gestreckt ist, es ist größer als es sein muss, als die body size, die ich von rtmp header erhalten habe. Und am wichtigsten ist, dass diese modifizierten Daten nicht das sind, was ich empfangen musste!
Meine Fragen sind: Wie kann es behoben werden? Was ist los mit InputStream? Warum fügt es diese 0xc6 Bytes in das empfangende Array ein?
Ich verstehe, dass ich empfangene Array einfach analysieren und diese zusätzlichen Bytes ausschließen kann, aber das ist schlechte Lösung, da Geschwindigkeit und Leistung erforderlich sind (und in diesem Fall ist es nicht klar, dass es ein zusätzliches Byte oder Byte aus der Quelle ist) der Vergleich von ganzer Arrays) ...

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

Nach dem RTMP spec verhält es sich ganz normal.Sie müssen die eingehenden Daten "entknüpfen", so dass das Lesen in einem einzigen Lesevorgang() nicht funktioniert.

Etwas in dieser Richtung (Pseudo-Code):

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

Wahrscheinlich, sollten Sie (und verwenden) Code von Red5 Media Server und anderen Open-Source-Lösungen sehen, die RTMP-Protokoll implementieren.

Answer 3

InputStream.read (Byte []) ist nur garantiert, ein Byte zu lesen, und es gibt die Länge als int der tatsächlichen Länge gelesen.

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. 

Wenn Sie nicht die tatsächliche Länge überprüfen und übernehmen die byte [] voll ist, können Sie bekommen, was Bytes, wo es, bevor Sie lesen() aufgerufen.

Was Sie da gedacht ist Datainputstream mit

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

Das Problem behoben ist.
Diese zusätzlichen 0xc6 Bytes waren die Chunking-Bytes des RTMP-Pakets, die vom WireShark nicht sichtbar waren.
Mehr als das, empfangen Header sagt die tatsächliche Körpergröße und WireShark "bestätigt" es, aber in der Tat wird die Körpergröße größer sein, und sollte berechnet werden.

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