Java - ObjectInputStream 소켓으로 듣기

Question

그래, 서버가 새로운 클라이언트를 만드는 연결을 수락 할 때마다 '클라이언트'라는 스레드 클래스가 있습니다 .... 실행 메서드는 클라이언트와 i에서 메시지를 수신합니다. 내가 루프의 끝에서 입력 스트림을 닫고 경우

do {    
     ObjectInputStream in = null; 

     try { 
      in = new ObjectInputStream(socket.getInputStream()); 
      String message = (String) in.readObject(); 
      System.out.println(message); 
      } 
      catch (ClassNotFoundException ex) { 
       isConnected = false; 
       System.out.println("Progoramming Error"); 
      } 
      catch (IOException ex) { 
       isConnected = false; 
       System.out.println("Server ShutDown"); 
       System.exit(0); 
      } 
    } while(isConnected); 

내가 가지고있는 문제를 ObjectInputStream에 ..

을 useing하고하는 이유는 새로운 ObjectInputStream에 그것을 루프마다 작성해야 할 것입니다 ... 그리고 루프 다시 다른 메시지가 나타납니다. 오류가 발생합니다.

Answer 1

클라이언트 연결을 위해 한 번만 (루프 외부에서) ObjectInputStream을 만든 다음 readObject 메소드를 루프에 추가합니다. ObjectStream의 저점을 보내이 예 문자열에서

public class TestPrg { 

    public static void main(String... args) throws IOException { 
     ServerListener server = new ServerListener(); 
     server.start(); 

     Socket socketToServer = new Socket("localhost", 15000); 
     ObjectOutputStream outStream = new ObjectOutputStream(socketToServer.getOutputStream()); 

     for (int i=1; i<10; i++) { 
      try { 
       Thread.sleep((long) (Math.random()*3000)); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
      System.out.println("Sending object to server ..."); 
      outStream.writeObject("test message #"+i); 
     } 
     System.exit(0); 

    } 

    static class ServerListener extends Thread { 

     private ServerSocket serverSocket; 

     ServerListener() throws IOException { 
      serverSocket = ServerSocketFactory.getDefault().createServerSocket(15000); 
     } 

     @Override 
     public void run() { 
      while (true) { 
       try { 
        final Socket socketToClient = serverSocket.accept(); 
        ClientHandler clientHandler = new ClientHandler(socketToClient); 
        clientHandler.start(); 
       } catch (IOException e) { 
        e.printStackTrace(); 
       } 
      } 
     } 
    } 

    static class ClientHandler extends Thread{ 
     private Socket socket; 
     ObjectInputStream inputStream; 

     ClientHandler(Socket socket) throws IOException { 
      this.socket = socket; 
      inputStream = new ObjectInputStream(socket.getInputStream()); 
     } 

     @Override 
     public void run() { 
      while (true) { 
       try { 
        Object o = inputStream.readObject(); 
        System.out.println("Read object: "+o); 
       } catch (IOException e) { 
        e.printStackTrace(); 

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

} 

:

여기에 작동 테스트 클래스입니다. ClassNotFoundException (http://download.oracle.com/javase/6/docs/api/java/io/ObjectInputStream.html#readObject())을 얻었고 독립적 인 클라이언트 및 서버 프로그램을 사용하고 있다면 다음을 확인하십시오. 클라이언트와 서버 모두 클래스 경로로 보낼 객체의 클래스를가집니다.