없이 StreamCorruptedException 잘못된 유형 코드 : 00

Question

서버 번호 :

while (true) {         
    Socket sock = serv.accept(); 
    try { 
     new ClientSession(sock, outQueue, activeSessions); 
     System.out.println("CS"); 
    } catch (IOException e) { 
     System.out.println("Sock error"); 
     sock.close(); 
    } 
} 

대로 ClientSession : 클라이언트 측에

가

public void connect() { 
    try { 
     InetAddress serverAddr = InetAddress.getByName(serverName); 
     try { 
      System.out.println("Connecting with " 
        + serverAddr.getHostName() + ":" + port); 
      socket = new Socket(serverAddr, port); 

      try { 
       System.out.println("Connected to " 
         + serverAddr.getHostName()); 
       netOut = new ObjectOutputStream(socket.getOutputStream()); 
       netOut.flush(); 
       netIn = new ObjectInputStream(socket.getInputStream()); 
       netOut.writeObject(new NameMessage(name)); 
       netOut.flush(); 
      } finally { 

      } 

     } catch (ConnectException e) { 
      System.out.println("Cannot connect to server"); 

     } catch (IOException e) { 
      System.out.println("Input error"); 
     } 

    } catch (UnknownHostException e) { 
     System.out.println("Unknown server: " + e.getMessage()); 
    } 
} 

수신기 :

class ClientSession extends Thread { 
private Socket socket; 
private OutboundMessages outQueue; 
private ActiveSessions activeSessions; 
private ObjectInputStream netIn; 
private ObjectOutputStream netOut; 
int n = 0; 
boolean inGame = false; 
boolean ready = false; 
Player p; 

public ClientSession(Socket s, OutboundMessages out, ActiveSessions as) 
     throws IOException { 
    socket = s; 
    outQueue = out; 
    activeSessions = as; 
    netOut = new ObjectOutputStream(socket.getOutputStream()); 
    netOut.flush(); 
    netIn = new ObjectInputStream(socket.getInputStream()); 
    System.out.println("ClientSession " + this + " starts..."); 
    while (true) { 
     Object nameMsg = null; 
     try { 
      nameMsg = netIn.readObject(); 
     } catch (ClassNotFoundException e) { 
      e.printStackTrace(); 
     } 
     if (nameMsg instanceof NameMessage) { 
      this.setName(((NameMessage) nameMsg).name); 
      break; 
     } 
    } 
    start(); 
} 

public void run() { 
    try { 
     activeSessions.addSession(this); 
     while (true) { 
      Object inMsg = null; 
      try { 
       try { 
        inMsg = netIn.readObject(); 
       } catch (ClassNotFoundException e) { 
        e.printStackTrace(); 
       } 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
      if (inMsg instanceof ReadyMessage) { 
       ready = true; 
      } else if (inMsg instanceof DirMessage) { 
       p.setDir(((DirMessage)inMsg).dir); 
      } 

     } 
    } finally { 
     try { 
      socket.close(); 
     } catch (IOException e) { 
     } 
    } 
} 

public void sendMessage(Message msg) { 
    try { 
     if (!socket.isClosed()) { 
      netOut.writeObject(msg); 
      netOut.flush(); 
     } else { 
      throw new IOException(); 
     } 
    } catch (IOException eee) { 
     try { 
      socket.close(); 
     } catch (IOException ee) { 
     } 
    } 
} 

클라이언트 측 입출력 생성

public void run() { 
    while (true) { 
     Object a = null; 

      try { 
       a = netIn.readObject(); 
       netIn.reset(); 
      } catch (ClassNotFoundException e) { 
       e.printStackTrace(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 

     if (a != null && a instanceof CoordMessage) { 
      setXY((CoordMessage)a); 
     } 
    } 
} 

스택 트레이스 :

java.io.StreamCorruptedException: invalid type code: 00 
at java.io.ObjectInputStream.readObject0(Unknown Source) 
at java.io.ObjectInputStream.readObject(Unknown Source) 
at twoPlayerClient.Receiver.run(Receiver.java:28) 

입력과 출력을 생성 한 후 나는 다른 클래스로에 전달하고 새로 작성하지 계속.

나는 다른 비슷한 질문을 읽었지만 이것이 계속 발생하는 이유에 대한 답을 찾을 수 없습니다.

Answer 1

new ClientSession(sock, outQueue, activeSessions); 

나는 클라이언트마다 새로운 세션이 있기 때문에 전역 변수와 함께 스트림 변수를 사용할 수 없다고 생각합니다. 이후 다른 세션 스레드에 의해 사용됩니다.