Java Server Socket Program

package server;

import java.net.*;

public class myServer {
   
    protected String version = "1.0"; //versions nummer for at tjekke protokol version
    protected Thread sst; //Variabel som holder ServerSocket Tråden
    protected Thread[] cst;  //Array med alle Client Socket Trådene
    private int port;  //Port
    private int slots;  //max antal clienter som kan tilslutte
   
    protected Message[] messages; //indeholder beskeder fraa clienttråde
   
    public static void main(String[] args) {
        myServer mS = new myServer();
        mS.setPort(18778);
        mS.setSlots(2);
        mS.run();
    }
   
    public void setPort(int port){
        this.port = port;
    }
    public int getPort(){
        return this.port;
    }
    public void setSlots(int slots){
        this.slots = slots;
    }
    public int getSlots(){
        return this.slots;
    }
   
    public void run(){
        cst = new Thread[this.getSlots()];
        this.messages = new Message[100];
        System.out.println("Starter Server");
        System.out.println("Lytter på port: "+ this.getPort());
        sst = new Thread(new ServerSocketThread(this));  //ligger ServerSocketThread i tråd, med ref til myServer
        sst.start(); //starter Serversocket tråd
    }
}

package server;

import java.net.*;
import java.io.*;
public class ServerSocketThread implements Runnable{
   
    myServer server; //bliver ref til myServer main tråden
    ServerSocket ss;  //bliver ServerSocket
   
    public ServerSocketThread(myServer server){
        this.server = server; //laver referancer til main thread
    }

    @Override
    public void run() {
       
        try {
            ss = new ServerSocket(server.getPort()); //opretter ServerSocket
           
            while(true)
            {
                Socket cs; //opretter clientsocket
                cs = ss.accept(); //overføre forbindelse til clientsocket
                System.out.println("Forbindelse fra "+ cs.getInetAddress().getHostAddress());
               
                ClientSocketThread tempcst = new ClientSocketThread(cs,server);
                for(int i = 0;i<server.cst.length;i++) //køre array igennem af tråde
                {
                    if(server.cst[i] == null || !server.cst[i].isAlive()){  //hvis denne tråd ikke bliver brugt
                      server.cst[i] = new Thread(tempcst); //ligger den indkommende client socket i sin egen tråd
                      tempcst.isAssigned = true;
                      tempcst.clienID = i;
                      server.cst[i].start();
                      break;
                    }
                }
                if(tempcst.isAssigned == false){
                    System.out.println("SERVER: kunne ikke forbinde, ikke nok slots");
                    cs.close();
                }
            }
           
        } catch (IOException ex) {}
    }
}

package server;

import java.net.*;
import java.io.*;
import java.util.logging.Level;
import java.util.logging.Logger;

public class ClientSocketThread implements Runnable{

    public boolean isAssigned;  //om denne er blevet lagt i array på ServerSocketThread
    public int clienID = 0;
    protected Socket cs;  //client Socket ref
    protected myServer server;  //ref til Main Thread
   
    private double lastmessage = 0;
    private PrintWriter out = null; //udegående tekst
    private BufferedReader in = null; //indgående tekst
   
    public ClientSocketThread(Socket cs, myServer server){
        this.lastmessage = System.currentTimeMillis();
        this.isAssigned = false;
        this.cs = cs;
        this.server = server;
    }
   
    @Override
    public void run() {       
        try {
            out = new PrintWriter(this.cs.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(this.cs.getInputStream()));
        } catch (IOException ex) {}
       
        System.out.println("Klient #"+this.clienID+" Forbundet");
       
        while(true)
        {
           
            try {
                if(in.ready())  //hvis der er data at skrive, som er klar
                {
                    String temp = in.readLine();
                    if(temp.equals("BYE")){
                        out.println("BYE BYE");
                        server.messages[0] = new Message(System.currentTimeMillis(),"Klient #"+this.clienID+" Afbrudt");
                        break;
                    }else{
                        server.messages[0] = new Message(System.currentTimeMillis(),"Klient #"+this.clienID+": "+temp);
                    }
                }
            } catch (IOException ex) {}
         
                for(int i = 0; i < server.messages.length;i++){
                    if(server.messages[i] != null && server.messages[i].date > this.lastmessage)
                    {
                        out.println(server.messages[i].message);
                    }
                }
                this.lastmessage = System.currentTimeMillis();
               
          try {
              Thread.sleep(20);
          } catch (InterruptedException ex) {}
        }
       
        System.out.println("Klient #"+this.clienID+" Afbrudt");
       
        try {
            this.cs.close();
        } catch (IOException ex) {}
    }
   
}

package server;


public class Message {
    public long date;
    public String message;
   
    public Message(long date, String message)
    {
        this.date = date;
        this.message = message;
    }
}

public synchronized void SendMessageGlobal(String message){
        server.messages[0] = new Message(System.currentTimeMillis(),"Klient #"+this.clienID+": "+message);
    }

public synchronized void SendMessageGlobal(String message){
        server.messages[0] = new Message(System.currentTimeMillis(),"Klient #"+this.clienID+": "+message);
    }

public class SharedData {
   
    private String text;
    private int num;
   
    public synchronized void setText(String text){
        try {
            Thread.sleep(1000);
        } catch (InterruptedException ex) {}
        this.num++;
        this.text = text;
    }
   
    public synchronized String getText(){
        return this.text;
    }
   
    public synchronized int getNum(){
        return this.num;
    }
}