ChatServer.java

package com.godoro.samples.net;

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

public class ChatServer extends Thread
{

  private List<ChatHandler> handlers = new ArrayList<ChatHandler>();
  private ServerSocket serverSocket;

  public ChatServer(int port)
    throws IOException
  {
    serverSocket = new ServerSocket(port);
  }

  @Override
  public void run()
  {
    System.out.println("Listening " + serverSocket.getLocalPort());
    while (true) {
      try {
        Socket socket = serverSocket.accept();
        System.out.println("A client connected");
        ChatHandler handler = new ChatHandler(this, socket);
        handlers.add(handler);
        handler.start();
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
  }

  public void send(ChatHandler sender,String message)
    throws IOException
  {
    for (ChatHandler handler : handlers) {
      if(handler != sender){
        handler.send(message);
      }
    }
  }

  public static void main(String[] args)
    throws Exception
  {
    ChatServer server = new ChatServer(9999);
    server.start();
  }
}