Wie kann ich einen ObjectInputStream erhalten, der Mark/Reset unterstützt?

Question

Ich versuche, eine ObjectInputStream zu bekommen, die es mir erlauben wird, Daten von ihm zu lesen, und, wenn es nicht vom richtigen Typ ist, setzen Sie die Daten wieder in den Strom (mit mark und reset) für einen anderen Code zu behandeln. Ich habe versucht, die InputStream aus dem Socket (s im folgenden Beispiel) in einer BufferedInputStream abgerufen vor dem Einwickeln in eine ObjectInputStream, wie ich glaubte, die Lösung zu sein, jedoch beim Aufruf ois.markSupported() wird immer noch falsch zurückgegeben. Unten ist dieser Versuch:

ois = new ObjectInputStream(new BufferedInputStream(s.getInputStream())); 

Jede Hilfe sehr geschätzt!

Answer 1

Ich würde eine höhere Abstraktion oben auf dem Stream erstellen. So etwas wie dieses (Pseudo-Code, nicht finalisiert):

public class Buffer { 
    private final ObjectInputStream in; 

    private Object current; 

    public Buffer(ObjectInputStream in) { 
     this.in = in; 
    } 

    public Object peek() { 
     if (current == null) { 
      current = in.readObject(); 
     } 
     return current; 
    } 

    public void next() { 
     current = in.readObject(); 
    } 
} 

Sie würden verwenden peek() wiederholt das aktuelle Objekt zu bekommen, und wenn es Ihnen passt, rufen Sie next() zum nächsten zu gehen.

Natürlich müssen Sie mit Ausnahmen umgehen, das Ende des Streams, schließen Sie es richtig, etc. Aber Sie sollten die Idee bekommen.

Oder, wenn Sie gerade alles im Speicher lesen kann, dann tun Sie es und eine Warteschlange mit den Objekten aus dem Stream erstellen, übergeben Sie dann die Warteschlange um und verwendet peek() und poll().