Java의 소켓 서버에서 objectOutputStream을 통해 전송 된 객체를 읽는 방법

Question

보내기가 작동하지만 서버 측에서 데이터 입력 스트림으로 전송 된 객체를받지 못합니다. 클래스는 직렬화되어 전송할 때 작동하지만 서버에서 왜 수신되지 않는지 잘 모르겠습니다. 모든 while 루프와 try에

Server.ois = new ObjectInputStream(client.getInputStream()); 
while(Server.ois.available() != 0) { 
    try { 
     TriangleSend ts = (TriangleSend)Server.ois.readObject(); 
     send(ts); 
     Server.ois.close(); 
    } catch (Exception e) { 
     continue; 
    } 
} 

:

여기 내 코드입니다. 또한 수신시 예외를 생성합니다.

는

센드는 (TriangleSend) 방법은 다음과 같습니다

public static void send(TriangleSend coords) { 
    for (Socket client : Server.clients) { 
     try { 
      if (client != null) { 
       try { 
        ObjectOutputStream oos = new ObjectOutputStream(client.getOutputStream()); 
        oos.writeObject(coords); 
        oos.flush(); 
       } catch (Exception e) {} 
      } 
     } catch (NullPointerException e) { 
      continue; 
     } 
    } 
} 

편집 : 소스 코드 예외 : http://pastebin.com/rYzqduer

을 heres 예외 :

java.io.StreamCorruptedException: invalid stream header: 73720027 
    at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:804) 
    at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299) 
    at com.gopro2027.lwjgl.server.ServerThread$1$1.run(ServerThread.java:88) 
    at java.lang.Thread.run(Thread.java:745) 
Could not send data Timeout: 0 

Answer 1

타일러 - 고객의 출력을 포장 ObjectOutputStream를 구축하기 전에 BufferedOutputStream로 스트림합니다. 반대로, c 전에 BufferedInputStream를 실행합니다. 서버 측의 ObjectInputStream의 온상입니다. 그것은 읽기/쓰기 프로세스에 도움이됩니다.

서버 측 :

Server.ois = new ObjectInputStream(new BufferedInputStream(client.getInputStream())); 
while(Server.ois.available() != 0) { 
    try { 
     TriangleSend ts = (TriangleSend)Server.ois.readObject(); 
     send(ts); 
     Server.ois.close(); 
    } catch (Exception e) { 
     e.printStackTrace(); 
     continue; 
    } 
} 

이 삼각형 보내기 :

public static void send(TriangleSend coords) { 
    for (Socket client : Server.clients) { 
     if (client != null) { 
      try { 
       ObjectOutputStream oos = new ObjectOutputStream(new BufferedOutputStream(client.getOutputStream())); 
       oos.writeObject(coords); 
       oos.flush(); 
      } catch (Exception e) { 
       e.printStackTrace(); 
      } 
     } 
    } 
} 

제거 편집

Answer 2

while(Server.ois.available() != 0) { 

available() 스트림의 마지막에 대한 유효한 시험이 아니다. Javadoc을 보라. 루프를 while (true)으로 변경하고 EOFException을 붙잡을 때 중단해야합니다.