Socket neue Referenz auf ObjectInputStream

[NagaraHyuga]

Hi,

Ich habe einen ObjectInputStream erzeut:

ObjectInputStream in = new ObjectInputStream(socket.getInputStream());

Nun möchte ich dem ObjectInputStream eine neue Referenz zuweisen:

in = new ObjectInputStream(socket.getInputStream());

Doch an dieser Stelle hängt sich das Programm einfach auf. Ich habe es auch schon debugged: Genau an dieser Stelle bleibt es hängen und geht nicht mehr weiter.

Weiß jemand warum das so ist und wie man es richtig hinbekommt??

MFG

 

[cr33p]

Probier mal den InputStream mit .close() zu schließen und dann neu zu referenzieren.

Falls das nicht hilft, setz nach dem close() den InputStream auf null (in = null; ) und refernzier ihn dann neu.

Falls das auch nicht hilft musst leider auf weitere Voschläge warten.

 

[HoaX]

a) Macht es eigentlich null Sinn was du da vor hast, wieso will man das?
b) ObjectInput/OuputStream verwendet intern ein eigenes Protokoll. Wenn du einen neuen OIS erstellst, dann wartet der auf einen Streamheader vom ebenfalls neuen OOS auf der Gegenseite, den es hier wohl nicht gibt.
c) Solltest du, wie cr33p vorgeschagen hat, versuchen den OIS zu schließen, so wird auch der darunterliegende Stram geschlossen -> Du musst deine Stream-Quelle erneut anzapfen/Verbindung aufbauen.

Edit: d) Am Ende hättest du ja dann zwei OIS auf einem Stream, das wird nicht funktionieren, da die sich dann gegenseitig die Datenpakete wegschnappen was dazu führt, dass bei keinem mehr ein valider Stream ankommt, Pakete verloren gehen, nurnoch Müll angkommt -> ne Exception fliegen wird.

 

[NagaraHyuga]

Hi,

mit close() kann ich es nicht machen, da dann auch die Socket-Verbindung geschlossen wird. Also ich habe mehrere Sockets in einer Hashmap gespeichert und EINEN ObjectInputStream. Ich möchte durch auswählen zwischen den Sockets hin und her switchen und natürlich auch den ObjectInputStream übernehmen.

Falls ihr eine bessere Möglichkeit habt, dann raus damit

 

[FArt]

Hi,

mit close() kann ich es nicht machen, da dann auch die Socket-Verbindung geschlossen wird. Also ich habe mehrere Sockets in einer Hashmap gespeichert und EINEN ObjectInputStream. Ich möchte durch auswählen zwischen den Sockets hin und her switchen und natürlich auch den ObjectInputStream übernehmen.

Falls ihr eine bessere Möglichkeit habt, dann raus damit

Wie?
Vielleicht solltest du beschreiben, was du mit diesem Konstrukt eigentlich erreichen möchtest. Es scheint, als hättest du das Konzept hinter Sockets noch nicht verstanden.

Wenn die Sockets in der Map stecken, kannst du dir immer den passenden InputStream geben lassen (die gehören zusammen). Konkurrierend da drauf zuzugreifen ist natürlich nicht sinnvoll.

 

[NagaraHyuga]

Also ich habe ein paar Socket-Verbindungen zu verschiedenen Clienten offen. Nun möchte ich entscheiden können, wem ich schreibe. Einmal dem und dann dem andern .

Jetzt habe ich es mit einer lokalen Variablen probiert:

ObjectInputStream in = new ObjectInputStream(socket.getInputStream());

Doch dann kommt diese Exeption:

java.io.StreamCorruptedException: invalid stream header: 73720015
at java.ibjectInputStream.readStreamHeader(Unknown Source)
at java.ibjectInputStream.<init>(Unknown Source)
at de.Test.SC$4.run(SC.java:543)
at java.lang.Thread.run(Unknown Source)

Die Socket-Verbindung ist auf jedenfall vorhanden (habe es mit System.out.println(socket); getestet)
Wo liegt denn dann der Fehler?? Warum wird diese Exception geschmissen??

 

[Murray]

Zu einem Socket darfst du immer nur einen ObjectInputStream aufmachen - merk dir doch die ObjectInputStreams, so wie du dir jetzt die Scokets merkst.

 

[NagaraHyuga]

Ok werd ich mal probieren Danke!!!

 

[FArt]

Nun möchte ich entscheiden können, wem ich schreibe.

Schreiben? InputStream?

Wenn du von mehreren InputStreams lesen möchtest, dann brauchst du mehrere Threads, da das lesen blockiert. Nonblocking IO geht mit Channels.

Die Socket-Verbindung ist auf jedenfall vorhanden (habe es mit System.out.println(socket); getestet)

Du hast getestet, ob du ein Socket-Objekt hast, das sagt noch nichts über den Zustand des Sockets aus.

Ich komme noch mal auf die Bemerkung zurück, dass du u.U. noch nicht weißt was du gerade tust, was Sockets sind und wie man diese verwendet.
Lesson: All About Sockets (The Java™ Tutorials > Custom Networking)
JDK 1.4.2 New I/O-related APIs & Developer Guides -- from Sun Microsystems

 

[FArt]

... habe ich noch vergessen...
java.io.StreamCorruptedException: invalid stream header: - Google-Suche

 

[NagaraHyuga]

Tut mir Leid hab mich verschrieben... Ich meine mit dem ObjectOutputStream nicht schreiben sondern ein Objekt verschicken. Und mit dem ObjectInputStream lese ich die Antworten(ebenfalls ein Objekt).

Ich habe jetzt eine HashMap extra für die ObjectInputStreams erstellt und füge sie dort hinzu.

 input.put(counter, new ObjectInputStream(socket
						.getInputStream()));

Doch taucht hier wieder mein Problem auf: Das Programm bleibt einfach an dieser Stelle stehen, egal wie lange ich warte...

 

[HoaX]

Gut dass ich schon in meinem Punkt d auf die Exception und deren Grund eingegangen bin ... Windmühlen usw ...

 

[FArt]

Gut dass ich schon in meinem Punkt d auf die Exception und deren Grund eingegangen bin ... Windmühlen usw ...

Es ist doch egal, wer die Lorbeeren erntet, wir sind doch eine Community... ;-)

Aber der Thread wird noch weiter gehen... ich hol schon mal Chips und Bier... sonst noch wer?

 

[NagaraHyuga]

Nein der Thread wird nicht weitergehen. Es klappt jetzt alles. Auf jedenfall vielen Dank!!! Ich musste nur erst den ObjectOutputStream erstellen(Client) , und dann den ObjectInputStream (Server)