ObjectInput-, ObjectOutputStream und flush()

Diese Seite verwendet Cookies. Durch die Nutzung unserer Seite erklären Sie sich damit einverstanden, dass wir Cookies setzen. Weitere Informationen

  • ObjectInput-, ObjectOutputStream und flush()

    Hallo,

    ich arbeite gerade an einem kleinen Servermodell. Dem liegt ein relativ einfaches Prinzip zu Grunde:
    Jeweils ein Server vertreten durch class Server extends BaseServer extends ServerSocket und Clients durch class Client extends BaseClient extends Socket.
    Beide Server und Client instanzieren eine Protokollklasse class BaseProtocol, welche Protokollthreads class BaseProtocolThread generieren kann.
    Diese Protokollthreads werden durch den Server generiert, wenn ein Client durch die accept()-Threadschleife verbunden wurde. Beim Client wird ein Protokollthread direkt nach dem Verbinden zum Server generiert.

    Ein Protokollthread kann nur mit einem Socket instanziert werden, da dieser auf den Output- und InputStream des Sockets zugreift.
    Der Thread handlet die Streams als ObjectInput- und ObjectOutputStream. Der Thread bestitz eine Schleife die auf 1 Byte wartet. Je nach Inhalt des Bytes wird eine interne Methode aufgerufen (0xC => readXYZRequest()), die dann von den Streams liest und wieder auf sie schreibt. Im Endeffekt ein Handler für Anfragen, die durch 1 Byte identifiziert werden. Zusätzlich bietet der Protokollthread die Möglichkeit eine Anfrage an die Gegenseite zu schicken (requestXYZ()).

    Im Idealfall sollte das so funktionieren (keine Subthreads):
    Clientseite:
    Serverseite

    1 schreibe meinAnfrageByte;
    2 schreibe meinStringXYZ;
    3 schreibe meinIntegerXYZ;
    4 schreibe meinObjectXYZ;
    5 flush;
    1 lese meinAnfrageByte;
    2 aufrufen readAnfrageRequest:
    3 lese meinStringXYZ;
    4 lese meinIntegerXYZ;
    5 lese meinObjectXYZ;
    6 verarbeiteDaten;
    7 schreibe meineAntwort;
    8 flush;
    6 lese meineAntwort;


    Leider funktioniert das nicht, denn ich bekomme eine StreamCorruptedException mit der Nachricht "invalid type code: 00" auf der Clientseite.
    Die Serverseite bekommt einfach nur eine EOFException spendiert, weil die Clientklasse den Socket schließt sobald ein unerwarteter Fehler auftritt.

    Ich bin mir nicht sicher, aber ich glaube das Protokoll des ObjectOutputStream funktioniert in etwa so (korrigiert mich wenn ich falsch liege):
    unsigned byte TypDerGesendetenDaten, unsigned scalar LängeDerDaten, byte[] SerialisierteDaten

    Aufgrund dieser Protokollstruktur, schließ ich einfach mal darauf, dass sich ein Nicht-Object-Packet eingeschlichen hat, obwohl ich ein Object lesen möchte. Bisher trat das Problem nämlich nur beim lesen der Antwort auf, die ein Object in meinem Fall ist. Meine Theorie ist, dass flush() etwas auf den Stream schreibt, dass readObject() aus dem ObjectInputStream davon abhält das Object korrekt zu lesen.

    Jedenfalls benötige ich das flush(), da ohne keine Daten ankommen. Der Sendepuffer ist anscheinend noch größer als geschriebene Daten.
    Vermutlich würde es ohne das flush() funktionieren. Leider konnte mir Google bis jetzt noch nicht so viel helfen, da es verschiedene "invalid type codes" gibt.

    Es ist etwas schwierig Codebeispiele zu posten, da das Servermodell in ein großes Projekt eingebunden ist. Ich hoffe Folgendes reicht um mein Problem zu verstehen:

    Schleife zum Lesen der Anfragen:

    Quellcode

    1. public void run(){
    2. System.out.println(getLogIdent() + " started");
    4. while(client.connected()){
    5. try {
    6. readLoop = true;
    7. byte preByte = input.readByte();
    9. switch(preByte){
    10. case PreBytes.Call:
    11. readCallRequest();
    12. break;
    14. case PreBytes.Auth:
    15. readAuthRequest();
    16. break;
    18. case PreBytes.Error:
    19. readErrorMessage();
    20. break;
    21. }
    22. }catch(IOException e){ // Hier wird die StreamCorruptedException gefangen, somit außerhalb des try-Blocks in der Funktion.
    23. System.out.println(getLogIdent() + " Exception caught: " + e.getClass().getName());
    25. if(e instanceof EOFException){
    26. client.disconnect();
    27. break;
    28. }else if(e instanceof SocketException){
    29. client.disconnect();
    30. }else{
    31. e.printStackTrace();
    32. }
    33. }
    34. }
    36. readLoop = false;
    37. System.out.println(getLogIdent() + " stopped");
    38. }
    Alles anzeigen


    readCallRequest():

    Quellcode

    1. private void readCallRequest() throws IOException {
    2. System.out.println(getLogIdent() + " Reading Call Request:");
    4. System.out.println(getLogIdent() + " Procedure Name");
    5. String procedureName = input.readUTF();
    6. System.out.println(getLogIdent() + " = " + procedureName);
    8. System.out.println(getLogIdent() + " Argument Length");
    9. int countArgs = input.readInt();
    10. System.out.println(getLogIdent() + " = " + countArgs);
    12. Object[] args = new Object[countArgs];
    14. try {
    15. for(int i = 0; i < args.length; i++){
    16. System.out.println(getLogIdent() + " Argument " + i);
    17. args[i] = input.readObject();
    18. System.out.println(getLogIdent() + " = " + args[i]);
    19. }
    21. System.out.println(getLogIdent() + " Running existence check");
    22. if(parent.containsKey(procedureName)){
    23. System.out.println(getLogIdent() + " Calling procedure");
    24. Object returnObject = parent.get(procedureName).call(this, args);
    26. System.out.println(getLogIdent() + " Writing Call Response");
    27. output.writeObject(returnObject);
    29. System.out.println(getLogIdent() + " Flushing");
    30. output.flush();
    31. }else{
    32. error(new ProcedureNotFound(procedureName));
    33. }
    34. }catch(ClassNotFoundException e){
    35. System.out.println(getLogIdent() + " Call Request failed due to type-missmatch");
    36. }catch(Exception e){
    37. System.out.println(getLogIdent() + " Exception caught: " + e.getClass().getName());
    38. }
    39. }
    Alles anzeigen


    Methode zum Senden einer call-Anfrage:

    Quellcode

    1. public Object call(String procedure, Object[] args){
    2. waitTillStarted();
    4. System.out.println(getLogIdent() + " calling Procedure: " + procedure);
    5. Object returnedObject = null;
    7. try {
    8. System.out.println(getLogIdent() + " Sending Call Request:");
    10. System.out.println(getLogIdent() + " PreByte " + PreBytes.Call);
    11. output.writeByte(PreBytes.Call);
    13. System.out.println(getLogIdent() + " Procedure Name " + procedure);
    14. output.writeUTF(procedure);
    16. System.out.println(getLogIdent() + " Argument Length " + args.length);
    17. output.writeInt(args.length);
    19. for(int i = 0; i < args.length; i++){
    20. System.out.println(getLogIdent() + " Argument " + i + " = " + args[i]);
    21. output.writeObject(args[i]);
    22. }
    24. System.out.println(getLogIdent() + " Flushing");
    25. output.flush();
    27. System.out.println(getLogIdent() + " Waiting for Call Response");
    28. returnedObject = input.readObject();
    29. }catch(IOException e){
    30. System.out.println(getLogIdent() + " Exception caught: " + e.getClass().getName());
    32. if(e instanceof EOFException){
    33. client.disconnect();
    34. }else if(e instanceof SocketException){
    35. client.disconnect();
    36. }else{
    37. e.printStackTrace();
    38. }
    39. }catch(ClassNotFoundException e){
    40. System.out.println(getLogIdent() + " receiving Call Response failed due to type missmatch");
    41. }
    43. System.out.println(getLogIdent() + " Returning Call Response");
    45. return returnedObject;
    46. }
    Alles anzeigen


    Wichig ist, dass wenn ich in Eclipse mir einen Breakpoint in die call()-Methode setze und dann schrittweise durchgehe entsteht kein Fehler.

    Könnt ihr mir Helfen, dass die Objects korrekt übertragen werden?
    Danke im Vorraus.
    IMP, out.

    Dieser Beitrag wurde bereits 2 mal editiert, zuletzt von TheIMP ()