ChatClient.java

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

public class ChatClient implements Runnable{
	private Socket socket = null;
	private Thread thread = null;
	private DataInputStream console = null;
	private DataOutputStream streamOut = null;
	private ChatClientThread client = null;

	public ChatClient(String serverName, int serverPort){
		System.out.println("Estableciendo conexion. Espere ... ...");

		try{
			socket = new Socket(serverName, serverPort);
			System.out.println("Conectado. " + socket);
			start();
		}
		catch(UnknownHostException uhe){
			System.out.println("Host desconocido: " + uhe.getMessage());
		}
		catch(IOException ioe){
			System.out.println("Excepcion: " + ioe.getMessage());
		}
	}

	public void run(){
		while(thread!=null){
			try{
				streamOut.writeUTF(console.readLine());
				streamOut.flush();
			}
			catch(IOException ioe){
			System.out.println("error: " + ioe.getMessage());
			}
		}
	}

	public void handle(String msg){
		if(msg.equals(".hasta luego")){
			System.out.println("Adios. Pulsa ENTER para salir ... ... ...");
			stop();
		}
		else{
			System.out.println(msg);
		}
	}

	public void start() throws IOException{
		console = new DataInputStream(System.in);
		streamOut = new DataOutputStream(socket.getOutputStream());

		if(thread == null){
			client = new ChatClientThread(this, socket);
			thread = new Thread(this);
			thread.start();
		}
	}

	public void stop(){
		if(thread != null){
			thread.stop();
			thread = null;
		}
		try{
			if(console != null)
				console.close();
			if(streamOut != null)
				streamOut.close();
			if(socket != null)
				socket.close();
		}
		catch(IOException ioe){  			
			System.out.println("Error ..."); 
		}
		client.close();  
		client.stop();
	}

	public static void main(String args[]){
		ChatClient client = null;
		if(args.length != 2)
			System.out.println("Uso: java ChatClient host(ej: localhost) port (usado en ClientServer)");
		else{
			client = new ChatClient(args[0], Integer.parseInt(args[1]));
		}
	}



}