ChatClient.java

package com.godoro.samples.net;

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

public class ChatClient extends Thread
{

  private Socket socket;
  private BufferedReader input;
  private PrintStream output;

  public ChatClient(String host, int port)
    throws IOException
  {
    socket = new Socket(host, port);
    InputStream in = socket.getInputStream();
    InputStreamReader reader = new InputStreamReader(in);
    input = new BufferedReader(reader);
    OutputStream out = socket.getOutputStream();
    output = new PrintStream(out);
  }

  @Override
  public void run()
  {
    while (true) {
      try {
        String message = input.readLine();
        if (message != null && !message.equals("")) {
          System.out.println("> " + message+"\n");
        }
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
  }

  public void send(String message)
    throws IOException
  {
    output.println(message);
  }

  public static void main(String[] args)
    throws IOException
  {

    ChatClient client = new ChatClient("localhost", 9999);
    client.start();
    System.out.println("Write your message and press 'Enter'");
    System.out.println("Enter 'exit' to exit \n");
    while (true) {
      InputStreamReader reader = new InputStreamReader(System.in);
      BufferedReader input = new BufferedReader(reader);
      String message = message = input.readLine();
      if (message.equals("exit")) {
        System.exit(0);
      } else {
        client.send(message);
      }
    }
  }
}