readObject가 응용 프로그램을 중단합니다.

Question

라이브 메신저 응용 프로그램을 만들려고합니다. 그러나 이유없이 ObjectInputStream에서 readObject를 시도 할 때 코드가 중단됩니다. 예외는 발생하지 않습니다.

try { 
    System.out.println("Trying to connect to server"); 
    socket = new Socket(InetAddress.getByName("localhost"),6789); 
    System.out.println("Connected to server"); 

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

    outputStream = new ObjectOutputStream(socket.getOutputStream()); 
    outputStream.flush(); 

    System.out.println("Streams are set up."); 

    window.toggleTyping(true); 
    System.out.println("Typing is now enabled"); 

    String inputMsg = null; 

    do { 
     try { 
      System.out.println("Reading object"); 
      inputMsg = (String)inputStream.readObject(); 
      System.out.println("Object read"); 

     } catch(ClassNotFoundException ee) { 
      System.out.println("Clas not found exception"); 
      ee.printStackTrace(); 
     } 

    } while(!inputMsg.equalsIgnoreCase("/exit")); 

    closeConnection(); 

}catch(IOException ex) { 
    ex.printStackTrace(); 
} 

마지막으로 출력되는 메시지는 "개체 읽기"입니다.

try { 
     serverSocket = new ServerSocket(6789); 
      System.out.println("Socket created. About to accept connections"); 
      Socket s = serverSocket.accept(); 
      new Thread(new Chat(s)).start(); 

    } catch(IOException e) { 
     e.printStackTrace(); 
    } 

그리고 클래스 채팅 :

public class Chat implements Runnable { 

private Socket socket; 
private ObjectOutputStream outputStream; 
private ObjectInputStream inputStream; 

public Chat(Socket s) { 
    System.out.println("Chat class constructor called"); 
    this.socket = s; 

    try { 
     outputStream = new ObjectOutputStream(socket.getOutputStream()); 
     outputStream.flush(); 

     inputStream = new ObjectInputStream(socket.getInputStream()); 
     System.out.println("Chat streams are now set up"); 

    }catch(IOException ex) { 
     ex.printStackTrace(); 
    } 


} 
private void closeChat() { 
    try { 
     outputStream.close(); 
     inputStream.close(); 
     socket.close(); 
     System.out.println("Chat is now closed"); 
    }catch(IOException ex) { 
     ex.printStackTrace(); 
    } 

} 

@Override 
public void run() { 
    System.out.println("Chat class method run called"); 
    try { 
     outputStream.writeObject("Connection is cool"); 
     outputStream.flush(); 
     System.out.println("Text sent"); 
     String inputMsg = ""; 
     do { 

      try { 
       inputMsg = (String)inputStream.readObject(); 
       System.out.println("Message read:"+inputMsg); 
      }catch(ClassNotFoundException e) { 
       e.printStackTrace(); 
      } 
     } 
     while(!inputMsg.equalsIgnoreCase("/exit")); 
     closeChat(); 
    } 
    catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 
} 

이유 모든 대화에서 다른 스레드가 내가 언젠가 한 채팅에서 여러 일을 구현할 계획입니다 것입니다.

Answer 1

이것은 읽기 방법이 차단 방법이기 때문입니다. 즉, 읽은 데이터가 완료되었음을 보여줄 때까지 -1을 얻을 때까지 읽으려고합니다. 이 소켓에 기입 해지는 OutputStream가 이것을 송신하고있는 것을 확인합니다. 따라서 데이터를 쓰거나 쓰기 후에 출력 스트림을 닫은 후에 소켓을 보내면 ObjectOutputStream.flush(); 메서드를 호출합니다. 아마도이 스트림을 나중에 처리하기 위해 추가 데이터를 보내고 싶을 수 있기 때문에이 하나를 닫지 마십시오.

---

그냥 일반적인 일이 : 당신이 그것을