Java - ObjectInputStreamでソケットを聴く

Question

これで、サーバーが新しいクライアントを作成する接続を受け入れるたびに、「クライアント」と呼ばれるスレッドクラスがあります。実行メソッドはクライアントからのメッセージをリッスンしますObjectInputStreamのに..

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); 

を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（））を取得し、独立したクライアントおよびサーバープログラムを使用している場合は、クライアントとサーバーの両方に、クラスパスで送信するオブジェクトのクラスがあります。