Objekte serialisieren

[Generic1]

Hallo,

ich bin gerade dabei, Objekte zwischen einem Server und einem Client hin und her zu schicken bekomme aber eine Exception EOFException. Weiß jemand was ich machen kann, um diese Exception zu beheben?
Vom Client wird ein Init an den Server gesendet und der Server sendet Objekte zum Client zurück, das klappt aber wenn ich in der Schleife wieder etwas zum Server sende und auf eine Antwort horchen will bekomme ich hier: while((receivedObject = ois.readObject()) != null) die Exception.
Kann ich da was machen oder Funktioniert das Objekte hin- und her schicken in einer while- Schleife nicht. EOF ist mir grundsätzlich von C noch klar, was das heißt: das ende einer Datei oder eines Streams wurde erreicht.

                    is = sslSocket.getInputStream();
                    final ObjectInputStream ois = new ObjectInputStream(is);
                    Object receivedObject = null;
                    while((receivedObject = ois.readObject()) != null) {      // hier bekomme ich die Exception
//beim zweiten Durchlauf
                        final List<T> readedObject = (List<T>)receivedObject;
                        for(final MyObject myObject : readedObject) {
                            System.out.println("Das ist das gelesene Object: " + myObject);
                            }
                        sendToServer(createACK());
                        }

java.io.EOFException
        at java.io.ObjectInputStream$BlockDataInputStream.peekByte(ObjectInputStream.java:2554)
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1297)
        at java.io.ObjectInputStream.readObject(ObjectInputStream.java:351)

 

[SlaterB]

vom Senden schreibst du nicht,
wenn der Server für jeden Sende-Vorgangen einen ObjectOutputStream neu öffnet und vor allem schließt,
dann ist nach dem ersten Schließen der Socket in diese Richtung für immer geschlossen

am besten postest du ein komplettes Testprogramm mit main-Methode und Server + Client im gleich Programm, zwei Threads oder so,
wenn das nicht geht, dann zumindestet etwas mehr vom Senden + Empfangen auf allen Seiten

 

[Generic1]

vom Senden schreibst du nicht,
wenn der Server für jeden Sende-Vorgangen einen ObjectOutputStream neu öffnet und vor allem schließt,
dann ist nach dem ersten Schließen der Socket in diese Richtung für immer geschlossen

Du hattest recht, ich hab einen ObjectOutputStream mehrmals geöffnet, das kann natürlich nicht funktionieren.

Hier noch mein Testprogramm (Client und Server), vielleicht brauchts ja mal jemand.

package serialclient;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Main {

    public Main() throws UnknownHostException, IOException, ClassNotFoundException {
        Socket s = new Socket("localhost", 3344);
        ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
        ObjectInputStream ois = new ObjectInputStream(s.getInputStream());
        System.out.println("Client started");
        oos.writeObject("Hallo vom Client init");
        Object o = null;
        while((o = ois.readObject()) != null) {
            System.out.println("Am Client: " + o);
            oos.writeObject("Hallo vom Client");
            oos.flush();
            }
        }

    public static void main(String[] args) throws UnknownHostException, IOException, ClassNotFoundException {
        new Main();
        }

}

package serialsend;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Main {

    public Main() throws IOException, ClassNotFoundException, InterruptedException {
        ServerSocket ss = new ServerSocket(3344);
        System.out.println("Server started");
        Socket s = ss.accept();
        ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
        ObjectInputStream ois = new ObjectInputStream(s.getInputStream());
        Object o = null;
        while((o = ois.readObject()) != null) {
            System.out.println("Am Server: " + o);
            oos.writeObject("Hallo vom Server");
            oos.flush();
            Thread.sleep(2000);
            }

        }

    public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {
        new Main();
        }
}