EOFException aber warum?

[sin]

public class UserHash implements Serializable{
	public Hashtable<String,String> table;
	public String file;
	public ObjectOutputStream objOS = null;
	public ObjectInputStream objIS = null;
	
	static final long serialVersionID = 100001;
	
	public UserHash(String file){
		this.file = file;
		try{
			objOS = new ObjectOutputStream(
				new BufferedOutputStream(
					new DataOutputStream(
						new FileOutputStream(this.file))));
			objIS = new ObjectInputStream(
				new FileInputStream(this.file));
		}
		catch(FileNotFoundException exc){
			exc.printStackTrace();
		}
		catch(EOFException exc){
			exc.printStackTrace();
		}
		catch(IOException exc){
			exc.printStackTrace();
		}
		try{
			table = (Hashtable<String,String>)objIS.readObject();
		}
		catch(ClassNotFoundException exc){

hallo, ich möchte einen ObjectInputStream initialisieren. Allerdings wird jedesmal eine EOFException geworfen. habe gelesen, dass diese am ende, beim auslesen eines Stream, ausgegeben wird. Aber ich initialisiere doch nur und verwende noch garnicht readObject(). Aus welchem Grund wird sie denn jetzt genau geworfen und wie kann ich meinen ObjectInputStream initialisieren?

vielen dank im voraus

gruß

 

[Gelöschtes Mitglied 5909]

was is das dann?

table = (Hashtable<String,String>)objIS.readObject();

 

[Guest]

was is das dann?

table = (Hashtable<String,String>)objIS.readObject();

das hat aber nichts mit der EOFException zu tun. hast du überhaupt gelesen wo mein fehler liegt ^^

gruß

 

[Gelöschtes Mitglied 5909]

at io.stream.UserHash.<init>(UserHash.java:28)

-> in der Datei muss vorher was stehen

* @throws IOException if an I/O error occurs while reading stream header

EOFException extends IOException

-> verwende 2 streams
-> versichere dass die datei nicht leer ist

// Edit
hab dir mal was gebastelt was dir später wohl noch helfen kann:

package io.stream;

import java.io.BufferedInputStream;
import java.io.EOFException;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.util.Iterator;
import java.util.NoSuchElementException;

public class GenericInputStream<E> extends ObjectInputStream implements
		Iterator<E>, Iterable<E> {

	private E	next	= null;

	public GenericInputStream( InputStream in ) throws IOException {
		super(in);
	}

	public GenericInputStream( File file ) throws FileNotFoundException,
			IOException {
		super(new BufferedInputStream(new FileInputStream(file)));
	}

	@Override
	@SuppressWarnings( "unchecked" )
	public boolean hasNext() {
		try {
			next = (E) readObject();
		} catch ( EOFException e ) {
			next = null;
			return false;
		} catch ( Exception e ) {
			next = null;
			throw new RuntimeException(e);
		}
		return true;
	}

	@Override
	public E next() {
		if ( next == null ) {
			throw new NoSuchElementException();
		}
		return next;
	}

	@Override
	public void remove() {
		throw new UnsupportedOperationException();
	}

	@Override
	public Iterator<E> iterator() {
		return this;
	}

}

 

[Guest]

vielen dank. wie meinst du das mit gleichzeitig lesen und schreiben? bzw. ich habe doch 2 streams einmal ObjIS & ObjOS. wieso ist es für den inputstream relevant ob etwas drinne steht? ich habe ja noch garnicht ausgelesen.

gruß

 

[Gelöschtes Mitglied 5909]

1. weil beide streams auf die gleiche datei verweisen und das in der regel in die hose geht (Entspricht dem sogenannten Reader / Writer Problem)

2. weil der ObjectInputStream beim aufruf vom Konstruktor versucht MetaDaten zu lesen -> wenn die Datei leer ist krachts

auszug aus der Api

    public ObjectInputStream(InputStream in) throws IOException {
	verifySubclass();
	bin = new BlockDataInputStream(in);
	handles = new HandleTable(10);
	vlist = new ValidationList();
	enableOverride = false;
	readStreamHeader();                                       <- !!!!!!!
	bin.setBlockDataMode(true);
    }

    protected void readStreamHeader()
	throws IOException, StreamCorruptedException
    {
	short s0 = bin.readShort();                         <- !!!!!!!!!
	short s1 = bin.readShort();                         <- !!!!!!!!!
	if (s0 != STREAM_MAGIC || s1 != STREAM_VERSION) {
	    throw new StreamCorruptedException(
		String.format("invalid stream header: %04X%04X", s0, s1));
	}
    }

 

[sin]

vielen dank, dass wusste ich garnicht