ChatHandler.java

package com.godoro.samples.net;

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

public class ChatHandler extends Thread
{

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

  public ChatHandler(ChatServer server, Socket socket)
    throws IOException
  {
    this.server = server;
    this.socket = socket;
    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("")) {
          server.send(this,message);
          send(">"+message);
        }
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
  }

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