ChatServer

/**
 *
 */
package chatServer;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
//import java.util.Queue;
/**
 * @author Patch
 *
 */
public class ChatServer extends Thread{
    private int id = -1;
    private static int port = 5689;
    private static boolean debug;
    private Socket clientSocket = null;
    private static ServerSocket serverSocket = null;
    private static final int MAX_CONNECTIONS = 10000;
    private static ChatServer[] serverThread = new ChatServer[MAX_CONNECTIONS];
    //TODO: private [] freeSlots;
    //private static Queue serverThreads = null; - An other possibility..
    private static int clientCount = 0;
    private BufferedReader in = null;
    private PrintWriter out = null;

    public ChatServer(Socket client, boolean debug, int port, int id) {
        this.clientSocket = client;
        this.debug = debug;
        this.port = port;
        this.id = id;
    }

    public void run() {
        System.out.println("Starting Server Thread!");

        try {
            this.in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            this.out = new PrintWriter(clientSocket.getOutputStream(),true);

            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                if (debug) {
                    System.out.println("Debug: " + inputLine);
                }
                synchronized (serverThread) {
                    for(int i=0; i < clientCount; i++) {
                        if(serverThread[i] != null && serverThread[i].out != null && serverThread[i]!= this) {
                            serverThread[i].out.println(inputLine);

                        }
                    }
                }

            }
            synchronized(this) {
                in.close();
                out.close();
                clientSocket.close();
                serverThread[this.id] = null;
                System.out.println("Client Disconnected");
            }

        }
        catch (IOException e) {
            System.err.print("Unbekannter Fehler: Kein Fehler!");
            e.printStackTrace();
        }

    }
    private static void parseArgs(String[] args) {
        switch (args.length) {
            case 0: debug = false; port = 5678; break;

            case 1: if (args[0].equalsIgnoreCase("-debug"))
                        {debug = true; port = 5678;}
                    if (args[0].matches("[-+]?\\d*\\.?\\d+") && 1023 <= Integer.parseInt(args[0]) && Integer.parseInt(args[0]) <= 49151)
                        {port = Integer.parseInt(args[0]);} break;

            case 2: if(args[0].equalsIgnoreCase("-debug"))
                        {debug = true;}
                    if(1023 <= Integer.parseInt(args[1]) && Integer.parseInt(args[1]) <= 49151)
                        {port = Integer.parseInt(args[1]);}break;

            default: System.err.println("Usage: java EchoServer [-debug][<port>]"); System.exit(1); break;
        }
    }
    private static void send(Socket client,String msg) throws IOException {
        PrintWriter out = new PrintWriter(client.getOutputStream());
        out.println(msg);
        out.close();
    }
    /**
     * @param args
     */
    public static void main(String[] args) {
        parseArgs(args);
        try {serverSocket = new ServerSocket(port);
        System.out.println("Server running on port " + port +". Debug: " + debug);
            while (true) {
                System.out.println("Wait for client connection to accept. (Connected Clients: " + clientCount + ")");
                Socket client = null;

                //synchronized (serverThread[clientCount]) {

                    if(clientCount < MAX_CONNECTIONS) {

                        client = serverSocket.accept(); //TODO
                        System.out.println("Client accepted");
                        synchronized(serverThread) {
                            (serverThread[clientCount] = new ChatServer(client, debug, port, clientCount)).start();
                            clientCount++;
                        }

                    }
                    else  {
                        System.err.println("Maximum Connection reached!");
                        send(client,"Server buys!");
                        }
                 }
            //}
        }
        catch (IOException e) {
            System.out.println("Exception caught when trying to listen on port "
                + port + " or listening for a connection");
            System.err.println(e.getMessage());
        }

    }

}