ChatClientThread.java

import java.net.*;
import java.io.*;
            
public class ChatClientThread extends Thread{

   private Socket           socket   = null;
   private ChatClient       client   = null;
   private DataInputStream  streamIn = null;

   public ChatClientThread(ChatClient _client, Socket _socket){  
      client   = _client;
      socket   = _socket;
      open();  
      start();
   }

   public void open(){  
      try{  
         streamIn  = new DataInputStream(socket.getInputStream());
      }
      catch(IOException ioe){  
         System.out.println("Error al abrir input stream: " + ioe);
         client.stop();
      }
   }

   public void close(){  
      try{  
         if (streamIn != null) streamIn.close();
      }
      catch(IOException ioe){  
         System.out.println("Error al cerrar input stream: " + ioe);
      }
   }

   public void run(){  
      while (true){  
         try{  
            client.handle(streamIn.readUTF());
         }
         catch(IOException ioe){  
            System.out.println("error: " + ioe.getMessage());
            client.stop();
         }
      }
   }
}