Abbruchbedingung readObject (deserialisieren)

[Reen]

Hallo!

Mal ne Frage. Wenn ich Objekte in einer Datei deserialisiere (Anzahl unbekannt), wie kann ich z.B. eine Abbruchbedingung für eine Schleife festlegen, bevor eine Exception geworfen wird?

Danke
Reen

 

[The_S]

Gehts nur mir so, oder verstehen auch andere absolut nicht, was du möchtest ???:L

 

[VuuRWerK]

Also so recht will mir auch nicht klar werden was der Kollege will, aber vllt solltest Du uns einfach mal Anteil haben lassen an einem Stück Deines so geheimnisvollen Quellcodes?

btw: wenn eine Exception gworfen wird dann liegt das u.U. daran das was falsch läuft? Hat man mir immer erzählt sowas ...

Gut Schuß
VuuRWerK

 

[Reen]

Ich poste heute abend mal den kompletten Code. Dann ist es vllt besser nachvollziehbar was ich genau meine :lol:

 

[Reen]

Oki Leute...dann hier mal der komplette Code. Der funzt auch soweit. Wichtig ist mir nur die Methode für das Deserialisieren der Objekte...

 private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException

Diese muss irgendwie per Schleife funktionieren. d.h. die Objekte sollen deserialisiert werden und z.B. muss das erste Objekt der Variable "kopf" zugeteilt werden, so wie ich es in der letzten Zeile der Funktion per Hand gemacht habe. Komischerweise funzt das aber auch nur, wenn ich aus der Instanzvariable "kopf" eine Klassenvariable (static) mache?
Außerdem soll jedem Vorgänger der korrekte Nachfolger zugeteil werden.

Wer hätte hier mal eine Idee, wie ich das machen könnte?

Danke
Reen

import java.io.*;
import java.util.ArrayList;

class Knoten implements Serializable {
    
	private static final long serialVersionUID = 11111L;
	
	public transient Knoten naechstes = null;
    public Object element   = null; 
    
    public Knoten(Object obj) {
       element = obj;           
    }
}


public class Kette implements Serializable {
    
	private static final long serialVersionUID = 11111L;
	
	 public static transient Knoten kopf = new Knoten("kopf");
    public transient Knoten ende = new Knoten("ende");

    public Kette() { 
        kopf.naechstes = ende;
        ende.naechstes = null;
    }                       

   
    public void fuegeNach(Knoten vorgaenger, Object neuObj) 
    {    
    	if  ( (vorgaenger == null) || (vorgaenger == ende) ) throw new RuntimeException("Vorgänger darf nicht null oder das Ende der Liste sein");
                
        Knoten neuKnoten = new Knoten(neuObj);
        neuKnoten.naechstes  = vorgaenger.naechstes;
        
        vorgaenger.naechstes = neuKnoten; 
    }

    
    public void ausgeben() {
        System.out.println(toString());
    }

 
    public String toString() {
        StringBuffer sb = new StringBuffer();

        Knoten aktuellerKnoten = kopf;
        System.out.println("Kopf " + kopf);
        
        for (int i=0; aktuellerKnoten!=null; i++) {
            sb.append("Knoten ").append(i).append(": ").append(aktuellerKnoten.element).append("\n");
            aktuellerKnoten = aktuellerKnoten.naechstes;
        } 
        sb.append(" ");

        return sb.toString();
    }
     
    
    public void speichern()  throws Exception 
    {
        FileOutputStream   fos = new FileOutputStream  ("vFAT.txt");
        ObjectOutputStream oos = new ObjectOutputStream(fos);
        oos.writeObject(this);
        oos.close();
    }

    
    private void writeObject(java.io.ObjectOutputStream out) throws IOException 
    {	
    	Knoten aktuellerKnoten = kopf;
    
    	for (int i=0; aktuellerKnoten!=null; i++) 
    		{ 	
    			out.writeObject(aktuellerKnoten);	
    			aktuellerKnoten = aktuellerKnoten.naechstes;		
    		} 
    }
   
   
    public static Kette laden() throws IOException, ClassNotFoundException 
    {	
    	FileInputStream   fis = new FileInputStream   ("vFAT.txt");
        ObjectInputStream ois = new ObjectInputStream (fis);
        Kette kette = (Kette)ois.readObject();
        ois.close();
        
        return kette;
    }

    
    private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException 
    {
      	Knoten knoten1 = (Knoten)in.readObject();
    	Knoten knoten2 = (Knoten)in.readObject();
    	Knoten knoten3 = (Knoten)in.readObject();
    	Knoten knoten4 = (Knoten)in.readObject();
    	
    	System.out.println(knoten1.element);
    	knoten1.naechstes = knoten2;
    	System.out.println(knoten2.element);
    	knoten2.naechstes = knoten3;
    	System.out.println(knoten3.element);
    	knoten3.naechstes = knoten4;
    	System.out.println(knoten4.element);
    	knoten4.naechstes = null;
    	
    	kopf = knoten1;
    	//System.out.println("kopf: " + kopf);
    	
    }
    
    
    @SuppressWarnings("deprecation")
	public static void main(String[] params) throws Exception 
    {
    	String eing, anzahl; 
		int anzahlint;
		
		Kette liste = new Kette ();
		
		BufferedReader eingabe = new BufferedReader(new InputStreamReader(System.in));
		BufferedReader anzahlk = new BufferedReader(new InputStreamReader(System.in));
		
		while (true)
		 {	
				System.out.print("Eingabe: ");
			    eing = eingabe.readLine();
			    char auswahl = eing.charAt(0);   
			    	
			    switch (auswahl)
			    	{	
			    		case 'a': liste.ausgeben();
			    					break;
			    					
			    		case 'c':   System.out.print("Anzahl der Kettenelemente? ");
						    		anzahl = anzahlk.readLine();
						    		anzahlint = Integer.parseInt(anzahl); 
						    		
						    		for (int i=1; i<=anzahlint; i++)
						    			{	
						    				byte[] index = new byte[7];		
						    				byte[] namefield = new byte[28]; 
						    				byte[] startp = new byte[10];
						    				byte[] endep  = new byte[10];
						    				byte[] laenge = new byte[10];
						    				byte[] nextc  = new byte[7];
						    					
						    				ArrayList<byte[]> al = new ArrayList<byte[]>();
						    				
						    				al.add(index);
						    				al.add(namefield);
						    				al.add(startp);
						    				al.add(endep);
						    				al.add(laenge);
						    				al.add(nextc);
						    				
						    			    liste.fuegeNach(liste.kopf, al);
						    			}
						    		liste.speichern();
							    	break;
			    		
			    		case 'l': liste.laden(); break;
			    		
			    		case 'q': System.exit(0); 
			    	} 
			   }
		    }
}

[/code]

 

[The_S]

Wie wärs mit Arrays oder Collections?

 

[hofi]

hallo

an deiner stelle würde ich zur serialsierung etwas wie xstream (http://xstream.codehaus.org/index.html) verwenden, da musst du dich nicht mit solchen blöden fehlern rumschlagen.

hab den code nicht ganz gelesen aber könnte mit vorstellen das das problem mit der klassenvariablen daran liegt, dass die klasse sich sozusagen selbst serialisert. würde den serialisierungsfunktionen in eine dritte klasse auslagern.

greetz

 

[Reen]

Danke euch erstmal für die Tipps.

Leider weiss ich jetzt auf die Schnelle nix mit Array's oder Collections anzufangen. Im großen und ganzen passt das ja schon. Mit XML hatte ich das auch schonmal versucht, aber das verbraucht für meine Zwecke einfach zuviel Speicher in der Datei, deshalb wollte ich das mit normalen Serialisieren hinbiegen. Das deserialisieren passt ja im Grunde auch schon, nur bekomme ich das korrekte zusammensetzen nich hin.

Dafür bräuchte ich mal ein paar Tipps.

Danke
Reen

 

[The_S]

Äh, Arrays und Collections sind elementar! Wie konntest du so ein Programm schreiben, ohne Ahnung von zumindest Arrays zu haben :shock: ? Wenn du dynamisch viele Objekte aufrufen/speichern/verwalten willst, dann wirst du um Arrays oder besser Collections/Listen nicht drum herum kommen!

http://www.galileocomputing.de/openbook/javainsel6/javainsel_03_009.htm#Xxx999775
http://www.galileocomputing.de/openbook/javainsel6/javainsel_11_001.htm#Xxx999368

 

[Reen]

Ja...was Array's sind weiss ich schon, ich kann mir gerade nix damit anfangen, wie ich damit mein Problem lösen könnte. Ich habe ja schon eine verkettete Liste.

Meinst du das so, dass ich alle Knoten jetzt zusätzlich in eine ArrayList schreiben soll und dann die ArrayList in die Datei schreiben könnte? Beim deserialisieren brächte ich dann nur ein (ArrayList) read.Object() machen und hätte dann meine Liste wieder im Ursprungszustand? Wenn es so wäre, dann habe ich vllt wieder das Problem, dass wenn ich die komplette ArrayList mit allen Knoten aufeinmal wegschreibe, ich wieder einen StackOverflowError bekomme.

mfg
Reen

 

[The_S]

Ne, du erstellst dir einfach eine ArrayList, in der du dann deine Knoten in einer Schleife einliest, bis keine mehr da sind.

Mir scheint aber, dass mir immer noch nicht ganz klar ist, wo dein Problem liegt ???:L

 

[Reen]

OKi...also nochma von vorn. Also ich habe ein verkettete Liste die ich in eine Datei schreibe. Die Verbindung zum nächsten Knoten setze ich "transient", weil durch die Rekursion ein StackOverflowError entsteht, wenn ich die komplette Liste mit einmal abspeichere. Deshalb werden alle Knoten von Hand einzeln in die Datei geschrieben.

Jetzt muss ich diese Knoten ja wieder aus der Datei bekommen und manuell die Referenz des Nachfolgers in den aktuellen Knoten setzten. Außerdem muss ich das erste Objekt mit der Variable "kopf" (die Klassenvariable) verbinden und meintwegen das letzte mit der Variable "ende".

Mein Ansatz sieht so aus, aber mit der Bedingung am Ende stimmt was nicht und ich bekomme auch keine gescheite hin, dass wenn er das Ende der Objekte in der Datei erreicht, aufhört zu deserialisieren. Versucht er ein Objekt zu deserialisieren, was nach dem ende nich mehr da ist, bekomme ich immer eine Exception. Lasse ich die Bedinung am Ende so stehen, dann hört ja folglich gleich nach dem ersten Objekt auf, weil der Nachfolger stehts "null" ist.

Denke jetzt habe ich mein Problem korrekt formuliert :lol:

 private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException 
    {
      	Knoten aktuellerKnoten = kopf;
       	String string;
      	
      	ArrayList neueKnoten = new ArrayList();
      	
      	do
      		{
      			Knoten knoten = (Knoten)in.readObject();
      			aktuellerKnoten = knoten;
      			neueKnoten.add(aktuellerKnoten);
      			
      			if (aktuellerKnoten.element instanceof String)
      				{	
      					string = (String) aktuellerKnoten.element;
      					
      					if (string.equals("kopf"))	
      						{	
      							System.out.println("KOPF");
      							//aktuellerKnoten = kopf;	
      						}
      					
      					if (string.equals("ende"))
      						{	System.out.println("ENDE");
      							aktuellerKnoten.naechstes = null;	
      						}
      				}
      		} while (aktuellerKnoten.naechstes == null);

 

[The_S]

Joa, jetzt ist denk ich alles klar. Du hast also mehrere Objekte in einer Datei, die du wieder einlesen möchtest. Dir ist aber nicht klar, wie du feststellen kannst, dass keine Objekte mehr in der Datei sind!?

Das nur so zur Wiederholung, nicht, dass ich schon wieder was falsch verstanden habe (mit bitte um Bestätigung).

 

[Reen]

Ganz genau so meinte ich das. Angenommen ich habe insgesamt 4 Objekte in der Datei, dann kann ich ja mit einer FOR-Schleife sagen, das er genau 4 Objekte einlesen soll.

Wenn ich das aber vorher nicht weiss, dann kann ich ja nicht unbedingt mit einer FOR-Schleife rangehen, sondern das Deserialisieren muss beim dem letzten Objekt aufhören bevor eine Exception kommt.

 

[The_S]

warum fängst du die Exception nicht einfach in einem try-catch block und beendest dann die Schleife? Oder serialisierst als erstes Objekt einen Integer, der speichert wie viele Objekte gespeichert wurden?

 

[schalentier]

Oder schreib als ersten Wert einen Int mit der Anzahl der Objecte? :shock:

/edit: ups, man sollte doch alles fertig lesen... sorry

 

[Reen]

Hallo Leute!

Ich habe das jetzt alles so hingebogen, wie ich mir das vorgestellt habe. Jetzt habe ich aber noch ein Problem und zwar wollte ich die Funktion zum Deserialisieren gern in eine eigene Klasse auslagern. Das funzt auch zum teil, aber eben nur zum teil.

public static Kette laden() throws IOException, ClassNotFoundException
    {   
      ***
    }

private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException
   { 
      ****
   }

Und zwar kann ich nur die obere der zwei Methoden in eine extra Klasse verlagern. Nehme ich die zweite auch mit, dann funzt das komischerweise nicht mehr. Lasse ich die zweite in der Klasse "Kette" und die erste in eine extra Klasse, dann gibts auch kein Problem. Klasse Kette wird in die neue vererbt, sowie der gleiche Konstructor wird genutzt. Es gibt auch keinen Fehler oda sowas. Das Proggi springt einfach nicht in die zweite Methode. Woran kann das denn liegen bzw. hat das was mit den Klassennamen zutun, das der einfach nur in der alten Klasse die zweite Methode ausführen kann???


Danke
Reen

 

[Leroy42]

An dem Modificator private natürlich.

Ändere den in public und deine
Probleme lösen sich in Wohlgefallen auf.

 

[Reen]

Nee...sorry. Das hatte ich auch schon versucht. Daran liegts leider nich!

 

[The_S]

Doch, 2. muss public sein, wenn sie ausgelagert wird. Außerdem solltest du z. B. ein Array mit den ausgelesenen Objekten zurückgeben.

 

[Reen]

Doch, 2. muss public sein, wenn sie ausgelagert wird.

Hmmm....wie gesagt. Das habe ich ja auch gedacht, aber es geht nicht. Ich habe mir auch schon in der 2ten eine Ausgabe erstellt, ob er überhaupt in diese Funktion geht. Und das macht das Proggi nicht. Er sucht diese Funktion in der Klasse Kette und da funzt sie ja auch.


Hier mal die einzelne Klasse. Vllt muss ich woanders noch irgendwas definieren??

class einlesen extends Kette
{
	private static final long serialVersionUID = 1L;


	public static Kette laden() throws IOException, ClassNotFoundException
    {   
       FileInputStream   fis = new FileInputStream   ("vFAT.txt");
        ObjectInputStream ois = new ObjectInputStream (fis);
        Kette kette = (Kette)ois.readObject();
        ois.close();
       
        return kette;
    }

   
    public void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException
    {
       System.out.println("Test");
       Knoten knoten1 = (Knoten)in.readObject();
       Knoten knoten2 = (Knoten)in.readObject();
       Knoten knoten3 = (Knoten)in.readObject();
       Knoten knoten4 = (Knoten)in.readObject();
       
       System.out.println(knoten1.element);
       knoten1.naechstes = knoten2;
       System.out.println(knoten2.element);
       knoten2.naechstes = knoten3;
       System.out.println(knoten3.element);
       knoten3.naechstes = knoten4;
       System.out.println(knoten4.element);
       knoten4.naechstes = null;
       
       kopf = knoten1;
       //System.out.println("kopf: " + kopf);
       
    }
}

 

[The_S]

Hast du evtl. irgendwo ein Zuordnungsproblem? Greifst du auf alte/falsche Resourcen zu?

Wenn etwas nicht geht, dann alles an Code mit angeben, der für uns von relevanz sein könnte. Außerdem noch die entsprechende Exception posten!

 

[Reen]

Code ist genau der Gleiche wie auf Seite 1, nur das beide Funktionen zum Deserialisieren in eine neue/extra Klasse ausgelagert werden.

Exception wird komischerweise auch keine geworfen und auf alte Referenzen zugreifen, dürfte eigentlich auch nicht der Grund sein.

 

[The_S]

Wenn der Code der gleiche ist, wie damals, als du noch alles in einer Klasse hattest, dann werden logischerweiße auch noch die Methoden Klassenintern aufgerufen :roll:

 

[Reen]

Wie darf man das denn verstehen? Wenn ich das Proggi neu starte, alles neu in die Datei reinschreibe, warum sollte der dann die ausgelagerten Methoden in der alten Klasse "Kette" suchen? Die Einlese-Methoden bleiben doch theor. unberührt solange ich die Datei nicht wieder einlese.

Das will mir jetzt nicht einleuchten! Logisch wäre es, wenn ich in die Datei geschrieben hätte und danach erst die Änderung mit der neuen Klasse im Code gemacht hätte. Es muss doch aber eine Lösung dafür geben!

 

[The_S]

Um Verwirrung (auf beiden Seiten) vorzubeugen, poste doch bitte nochmal deinen momentan aktuellen Code inkl. der (nicht funktionierenden) Auslagerung.

 

[Reen]

import java.io.*;
import java.util.ArrayList;

class Knoten implements Serializable {
   
   private static final long serialVersionUID = 1L;
   
   public transient Knoten naechstes = null;
    public Object element   = null;
   
    public Knoten(Object obj) {
       element = obj;           
    }
}


public class Kette implements Serializable {
   
   private static final long serialVersionUID = 11111L;
   
    public static transient Knoten kopf = new Knoten("kopf");
    public static transient Knoten ende = new Knoten("ende");

    public Kette() {
        kopf.naechstes = ende;
        ende.naechstes = null;
    }                       

   
    public void fuegeNach(Knoten vorgaenger, Object neuObj)
    {   
       if  ( (vorgaenger == null) || (vorgaenger == ende) ) throw new RuntimeException("Vorgänger darf nicht null oder das Ende der Liste sein");
               
        Knoten neuKnoten = new Knoten(neuObj);
        neuKnoten.naechstes  = vorgaenger.naechstes;
       
        vorgaenger.naechstes = neuKnoten;
    }

   
    public void ausgeben() {
        System.out.println(toString());
    }


    public String toString() {
        StringBuffer sb = new StringBuffer();

        Knoten aktuellerKnoten = kopf;
        System.out.println("Kopf " + kopf);
       
        for (int i=0; aktuellerKnoten!=null; i++) {
            sb.append("Knoten ").append(i).append(": ").append(aktuellerKnoten.element).append("\n");
            aktuellerKnoten = aktuellerKnoten.naechstes;
        }
        sb.append(" ");

        return sb.toString();
    }
     
   
    public void speichern()  throws Exception
    {
        FileOutputStream   fos = new FileOutputStream  ("vFAT.txt");
        ObjectOutputStream oos = new ObjectOutputStream(fos);
        oos.writeObject(this);
        oos.close();
    }

   
    private void writeObject(java.io.ObjectOutputStream out) throws IOException
    {   
       Knoten aktuellerKnoten = kopf;
   
       for (int i=0; aktuellerKnoten!=null; i++)
          {    
             out.writeObject(aktuellerKnoten);   
             aktuellerKnoten = aktuellerKnoten.naechstes;      
          }
    }
   
   
   public static void main(String[] params) throws IOException
    {
       String eing, anzahl;
      int anzahlint;
      
      Kette liste = new Kette ();
      
      BufferedReader eingabe = new BufferedReader(new InputStreamReader(System.in));
      BufferedReader anzahlk = new BufferedReader(new InputStreamReader(System.in));
      
      while (true)
       {   
            System.out.print("Eingabe: ");
             eing = eingabe.readLine();
             char auswahl = eing.charAt(0);   
                
             switch (auswahl)
                {   
                   case 'a': liste.ausgeben();
                            break;
                            
                   case 'c':   System.out.print("Anzahl der Kettenelemente? ");
                            anzahl = anzahlk.readLine();
                            anzahlint = Integer.parseInt(anzahl);
                            
                            for (int i=1; i<=anzahlint; i++)
                               {   
                                  byte[] index = new byte[7];      
                                  byte[] namefield = new byte[28];
                                  byte[] startp = new byte[10];
                                  byte[] endep  = new byte[10];
                                  byte[] laenge = new byte[10];
                                  byte[] nextc  = new byte[7];
                                     
                                  ArrayList al = new ArrayList();
                                  
                                  al.add(index);
                                  al.add(namefield);
                                  al.add(startp);
                                  al.add(endep);
                                  al.add(laenge);
                                  al.add(nextc);
                                  
                                   liste.fuegeNach(liste.kopf, al);
                               }
                            try {
						liste.speichern();
					} catch (Exception e1) {
						// TODO Auto-generated catch block
						e1.printStackTrace();
					}
                            break;
                   
                   case 'l': try {
						einlesen.laden();
					} catch (ClassNotFoundException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					} break;
                   
                   case 'q': System.exit(0);
                }
            }
          }
} 

class einlesen extends Kette
{
	private static final long serialVersionUID = 1L;


	public static Kette laden() throws IOException, ClassNotFoundException
    {   
       FileInputStream   fis = new FileInputStream   ("vFAT.txt");
        ObjectInputStream ois = new ObjectInputStream (fis);
        Kette kette = (Kette)ois.readObject();
        ois.close();
       
        return kette;
    }

   
    public void readObject(java.io.ObjectInputStream in)
    {
       System.out.println("Test");
       Knoten knoten1;
	
       try {
			knoten1 = (Knoten)in.readObject();
		 
			Knoten knoten2 = (Knoten)in.readObject();
			Knoten knoten3 = (Knoten)in.readObject();
			Knoten knoten4 = (Knoten)in.readObject();
	       
	       System.out.println(knoten1.element);
	       knoten1.naechstes = knoten2;
	       System.out.println(knoten2.element);
	       knoten2.naechstes = knoten3;
	       System.out.println(knoten3.element);
	       knoten3.naechstes = knoten4;
	       System.out.println(knoten4.element);
	       knoten4.naechstes = null;
       
	       kopf = knoten1;
	       //System.out.println("kopf: " + kopf);
		}
       	catch (IOException e) {	e.printStackTrace();	} 
       	catch (ClassNotFoundException e) {	e.printStackTrace();	}
       
    }
}

 

[The_S]

Ich sehe keinen Aufruf deiner readObject Methode :bahnhof:

 

[Reen]

Ich sehe keinen Aufruf deiner readObject Methode

Hatte ich doch vorher auch nicht bzw. wie rufe ich so eine Methode auf? Hier habe ich ja keine Referenzvariable bzw. was soll ich hier als Parameter übergeben?

thx
Reen

 

[The_S]

Wenn du readObject nie aufrufst, warum wunderst du dich dann, dass du dich nie in der Methode befindest :shock: ?

Du rufst sie so wie jede andere Methode auch auf. Übergeben tuste einen ObjectInputStream, der auf deine gespeicherten Objekte zeigt ...

 

[Reen]

grrrr Scheissendreck :lol:

Ich habe keinen Plan wie du das meinst. Mir ist klar, dass ich die Funktion mit "readObject(irgendwas)" aufrufen muss. Aber hier hörts dann schon auf. An welcher Stelle sollte ich die Funktion aufrufen und was muss ich denn übergeben Syntaxtechnisch ???:L Gib mal bitte bissl Code an, sonst frage ich dich morgen immer noch

Und wie kannst du mir das erklären, dass ich vorher die 2.ten Funktion nicht seperat aufrufen musste, aber ausgerechnet jetzt?

Danke

 

[The_S]

Ich hab keine Ahnung, was du vorher gemacht hast, aber wenn du eine Methode nicht aufrufst, wird sie auch nicht ausgeführt. Es sei denn sie ist static oder steht in der main-Methode.

Wenn du keinen Plan hast, wie man eine Methode aufruft und was es mit Klassen und Objekten zu tun hat, dann empfehle ich dir dringend nochmal die ersten (inkl. OOP) Kapitel der Java-Insel durchzulesen. Ansonsten erklär ich mich nämlich auch noch nächste Woche dumm und deppert .