nowy ObjectInputStream() blokuje

Question

public class SerProg { 


    static ServerSocket ser=null; 
    static Socket cli=null; 
    static ObjectInputStream ins=null; 
    static ObjectOutputStream outs=null; 


    public static void main(String[] args) { 

     try { 

      ser=new ServerSocket(9000,10); 
      cli=ser.accept(); 

      System.out.println("Connected to :"+cli.getInetAddress().getHostAddress()+" At Port :"+cli.getLocalPort()); 

      ins=new ObjectInputStream(cli.getInputStream()); 
      outs=new ObjectOutputStream(cli.getOutputStream()); 

      String str=(String)ins.readObject(); 


     } catch (Exception e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 


    } 

} 

a klient

public class SerProg { 

    /** 
    * @param args 
    */ 
    static ServerSocket ser=null; 
    static Socket cli=null; 
    static ObjectInputStream ins=null; 
    static ObjectOutputStream outs=null; 


    public static void main(String[] args) { 
     // TODO Auto-generated method stub 

     try { 

      ser=new ServerSocket(9000,10); 
      cli=ser.accept(); 

      System.out.println("Connected to :"+cli.getInetAddress().getHostAddress()+" At Port :"+cli.getLocalPort()); 

      ins=new ObjectInputStream(cli.getInputStream()); 
      outs=new ObjectOutputStream(cli.getOutputStream()); 

      String str=(String)ins.readObject(); 


     } catch (Exception e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 


    } 

} 

połączenie zostanie nawiązane pomyślnie, ale w linii kodu serwera

ins=new ObjectInputStream(cli.getInputStream()); 

kod zatrzymuje i nie dokonuje, co może być problem ??

Answer 1

Musisz utworzyć ObjectOutputStream przed ObjectInputStream po obu stronach połączenia (!). Po utworzeniu ObjectInputStream próbuje odczytać nagłówek strumienia obiektu od InputStream. Jeśli więc nie został jeszcze utworzony ObjectOutputStream po drugiej stronie, nie ma nagłówka strumienia obiektu do odczytania i będzie on blokował się w nieskończoność.

Albo inaczej sformułowane: jeśli obie strony najpierw skonstruują ObjectInputStream, obie będą blokować próby odczytania nagłówka strumienia obiektu, który nie zostanie zapisany do momentu utworzenia ObjectOutputStream (po drugiej stronie linii); co nigdy nie nastąpi, ponieważ obie strony są zablokowane w konstruktorze ObjectInputStream.

Można to wywnioskować z Javadoc z ObjectInputStream(InputStream in):

serializacji strumień nagłówek jest czytać ze strumienia i zweryfikowane. Ten konstruktor będzie blokował dopóki odpowiedni ObjectOutputStream nie napisze i nie przepuści nagłówka.

ta jest także opisana w punkcie 3.6.2 Podstawowych sieci w Javie przez Esmond Pitta.