ChatServerThread.java

import java.net.*;
import java.io.*;

public class ChatServerThread extends Thread{
	private ChatServer server = null;
	private Socket socket = null;
	private int ID = -1;
	private DataInputStream streamIn = null;
	private DataOutputStream streamOut = null;

	public ChatServerThread(ChatServer _server, Socket _socket){
		super();
		server = _server;
		socket = _socket;
		ID = socket.getPort();
	}

	public void send(String msg){
		try{
			streamOut.writeUTF(msg);
			streamOut.flush();
		}
		catch(IOException ioe){
			System.out.println(ID + " ERROR sending: " + ioe.getMessage());
			server.remove(ID);
			stop();
		}
	}

	public int getID(){
		return ID;
	}

	public void run(){
		System.out.println("Hebra del server " + ID + " ejecutandose.");
		
		do{
			try{
				server.handle(ID, streamIn.readUTF());
			}
			catch(IOException ioe){
				System.out.print(ID + "Error lectura: " + ioe.getMessage());
				server.remove(ID);
				stop();
			}
		}while(true);
	}

	public void open() throws IOException{
		streamIn = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
		streamOut = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
	}

	public void close() throws IOException{
		if(socket != null)
			socket.close();
		if(streamIn != null)
			streamIn.close();
		if(streamOut != null)
			streamOut.close();
	}


}