Socket Socket In-Buffer leeren

[Philipp91]

Hallo,

ich habe folgende Ausgangssituation:
Ich sende über TCP Daten von C# nach Android/Java. Es gibt eine Steuerverbindung (über die noch viele andere Sachen laufen, u.a. auch, welche Datei gleich auf der Datenverbindung ankommt) und eben diese Datenverbindung, auf der alle übertragenen Daten die Größe 4608 Bytes haben.
Auf der Java-Seite haben beide TCP-Verbindungen ein java.net.Socket, das aus ServerSocket.accept() kommt, im Falle der Steuerverbindung sind um die beiden Streams noch Reader-Klassen drumrum, aber auf der Datenverbindung wird nur gelesen, und zwar, indem direkt vom InputStream die .read-Methode für 4608 Bytes aufgerufen wird. C# sendet mit System.Net.Socket.Send() - wahlweise auch asynchron.

Jetzt ergibt sich folgendes Problem:
Über die Steuerverbindung wird immer mal wieder eine Flut von Daten (z.B. 500*4608 Bytes) angestoßen. Über die Steuerverbindung schickt C# dann die 500 Infos und über die Datenverbindung die 500 Daten, wobei letzteres nicht flüssig durchläuft, sondern dann verlangsamt, wenn Android nicht mehr hinterherkommt und auch der/die? Buffer voll sind.
Jetzt kann es aber sein, dass Android findet, das reicht (weil die Activity geschlossen wird und eine andere aufgerufen wird). Dann wird über die Steuerverbindung ein neuer Datenstrom initiiert, aber es kommt JEDES MAL noch ein Rest vom vorherigen Datenstrom an, wenn der noch nicht vollständig abgearbeitet war. Dadurch kommen die Daten natürlich völlig durcheinander.

Also brauche ich:
Sowohl bei C#, aber insbesondere bei Java eine Funktion, um zu sagen: ignoriere alles, was jetzt grade noch ankommt. Am besten soll der Thread so lange blockiert werden, bis er mit dem Ignorieren fertig ist, damit ich dann mit dem Anfragen der neuen Datenmenge weitermachen kann.
Socket.skip() bzw. auch .read() wollen leider eine Byte-Zahl wissen, die weiß ich aber nicht. Die Dokumentation sagt, dass .available() ungenau ist.

Wäre nett, wenn ihr einem C#er sagen könnt, wie man das unter Java realisiert - aber um ehrlich zu sein, habe ich unter C# die Funktion auch nicht gefunden.

Vielen Dank für eure Hilfe
Philipp

 

[SlaterB]

grundsätzlich gilt: wie liest du bisher Daten? es muss doch einen eigenen Thread oder so geben, der ständig an der Verbinung horcht und nach nicht vorhersagbarer Zeit einzelne Bytes oder ein Byte-Array an Daten liefert,
zwischendurch blockiert der Thread sowieso, macht nichts anderes als am Socket zu lesen,
wenn mit Timeout, dann evtl. alle x sec kurz Pause, auch ohne neue Daten,

dies ist deine Komponente, alle Daten die geschickt werden kommen dort an, zeitlich etwa so schnell wie möglich,
was immer du jetzt zusätzlich einbauen willst, kannst du an dieser Stelle bauen,
z.B. kannst du dem Thread ein boolean ignore true/false geben, wenn du das aktuell auf true stellst und in den nächsten ms etwas ankommt, dann wird das eben nicht zur Verarbeitung weiter gereicht,
nach 5 sec stellst du ignore auf false, und was in 7 sec gesendet wird geht gewiss nicht verloren,

etwas problematisch ist, wenn zu einem Zeitpunkt ein Array mit 400 Bytes gelesen werden, von denen die ersten 300 noch alte Daten sind, die letzten 100 aber wichtige neue,
wenn das zeitlich so end zusammenliegt, kommt man mit einfachen boolean nicht mehr weit,
diese Daten müssen dann eher manuell durchsucht werden (nach neuen Beginn-Byte-Signatur),

oder etwas in der Richtung von Thread-Einstellung 'ignoriere die nächsten 350 Bytes', wenn dei Zählung und Zeitpunkt der Einstellung so genau zu kontrollieren sind

 

[Philipp91]

Hallo SlaterB,

vielen Dank für deine Antwort!

Ich weiß nicht, ob ich deine Antwort ganz richtig verstanden habe, jedenfalls ist (vermutlich dementsprechend) mein Ansatz, dass der Thread - der bereits existiert hat - einfach über die Datenverbindung informiert wird, welche Daten ankommen. Der Steuer-Thread entscheidet dann, ob er die haben will. Der Vorteil ist, dass der Daten-Thread alles empfangen kann und erst einmal selbst auswertet, sodass Information über die Daten (ehemals Steuerverbindung) und die Daten selbst gar nicht getrennt ankommen können.

Ich muss allerdings zugeben, dass ich es dennoch nicht hinbekommen habe, das Gemülle so schnell zu stoppen/zu ignorieren und die wirklichen Daten dann zu empfangen, wie es eigentlich nötig wäre, für einen flüssigen Betrieb (weil eben doch einiger Müll ankommt und ziemlich lange den Buffer verstopft. Ich habe deshalb noch etwas anderes geändert: Ich habe einen Datensocket-Pool, ein Extra-Thread sorgt dafür, dass da immer so 3-5 offene, unbenutzte Verbindungen drin sind und öffnet bei Bedarf neue. Wenn Daten übertragen werden sollen, holt sich die Steuerverbindung einfach eine der Datenverbindungen dazu, und wenn sie sich für den noch ankommenden Müll nicht mehr interessiert, dann macht sie die Datenverbindung einfach wieder zu und benutzt für die nächsten Daten dann ein neues Socket - dadurch ist das Müllproblem gelöst.
Dann habe ich noch den Buffer vergrößert (auf 2 MB!), was einen enormen Geschwindigkeitsschub gebracht hat, und außerdem habe ich das Suchen nach einer Beginn-Byte-Signatur gelöst, indem immer VOR den Daten die Länge danach kommenden Daten übertragen wird, sodass man die Beginn-Signatur nicht mehr braucht.


Vielen Dank für deine Hilfe - das Problem ist damit gelöst!
Viele Grüße
Philipp