Quellcode

/*
toDo:

knt:Entfernen der verbindungen zu clients (removeClient)
	die daten im vektor rutschen nach d.h. es gibt keinen
	festen index für die elemente
	Das ansprechen muss anders gesehen ich glaube es gibt eine getObject(obj)
*/
import java.util.*;
import java.io.*;
import java.net.*;

public class CChatServer implements IListenAble
{
	private int port;
	private Vector clientList = new Vector();
	private ServerSocket clientListener;

	//konstruktor
	CChatServer(int port)
	{
		try
		{clientListener = new ServerSocket(port);}
		catch(IOException ioe)
		{System.out.println ("** Fehler beim initialisieren: " +ioe);}
		System.out.println("** chatServer auf Port " + port + " initialisiert");

	}

	//lauscht nach neuen clients
	public void listen()
	{
		Socket clientSock;

		System.out.println("** chatServer lauscht auf verbindungen");
		System.out.println("***************************************\n");
		try
		{
			while(true)
			{
				clientSock = clientListener.accept();
				System.out.println("accept: " + clientSock.toString());
				addClient(clientSock);
			}
		}
		catch(IOException ioe)
		{System.out.println("** Fehler beim lauschen auf verbindunen: " + ioe);}
	}

	//erstellt eine Verbindung zu einem Client
	//und fügt diesen zu einem Vector hinzu
	private boolean addClient(Socket clientSock)
	{
		CListener l;
		int id;
		try
		{
			//BufferedReader in = new BufferedReader(new InputStreamReader(clientSock.getInputStream()));
			PrintWriter out = new PrintWriter(clientSock.getOutputStream());

			clientList.addElement(out);
			id = clientList.size()-1;
			Thread t = new Thread(l = new CListener(clientSock, this, id));
			t.start();
			System.out.println("verbindung zu client " + id +" erstellt");
		}
		catch(IOException e)
		{System.out.println("** Fehler beim erstellen der Verbindung: " + e);}

		return true;
	}

	//beendet eine Verbinung zu einem Client
	//und löscht diesen aus dem Vector
	public boolean removeClient(int clientId)
	{
		System.out.println ("** connection zu client: " + clientId + " abgebrochen.");

		try
			{clientList.removeElementAt(clientId);}
		catch (Exception e)
			{System.out.println ("Fehler beim Entfernen eines Clients\nClientID: " + clientId + "\nClientListrSize: " + clientList.size());}

		return true;
	}

	//sendet einen String an alle Clients
	//public void boardcaste(String line, int id)
	public void processLine(String line)
	{
		try
		{
			for (int x=0;x<=clientList.size()-1;x++)
			{
				PrintWriter out = (PrintWriter) clientList.elementAt(x);
				out.println(line);
				out.flush();
				System.out.println("** client send \"" + line + "\" to client "+ x);
			}
		}
		catch (Exception e)
			{System.out.println ("Fehler beim senden der Nachricht");}
	}

	public void endConnection(int Id)
	{
		removeClient(Id);
	}

	//die main parst die argumente und startet den Server
	public static void main(String[] args)
	{
		CChatServer srv;
		int port;

		System.out.println("** chatServer 0.1 by knt at 04.03.01 **");
		System.out.println("***************************************\n");

		if (args.length < 1)
		{// zuwenig oder falsche Argumente
			System.out.println("Du hast zuwenig Argumente um mich zu nutzen.\n Aufruf:\tserver port");
			return;
		}

		port = Integer.parseInt(args[0]);

		srv = new CChatServer(port);

		srv.listen();

		System.out.println("/nTschau!");
	}
}
-CChatClient-
Code:
import java.io.*;
import java.net.*;

public class CChatClient implements IListenAble
{
	public static void main(String[] args)
	{
		if (args.length < 2)
		{// zuwenig oder falsche Argumente
			System.out.println("Du hast zuwenig Argumente um mich zu nutzen.\n Aufruf:\tclient ip port");
			return;
		}

		String ip = args[0];
		int port = Integer.parseInt(args[1]);

		CChatClient obj = new CChatClient();
		obj.listen(ip, port);
		System.out.println("Tschau!\n");

	}


	public void listen(String ip, int Port)
	{
		Socket serverSock;
		BufferedReader stIN;
		String line;
		System.out.println("HI!\n");

		try
		{
			serverSock = new Socket(ip, Port);

			PrintWriter out = new PrintWriter(serverSock.getOutputStream());

			Thread t = new Thread(new CListener(serverSock, this, 0));
			t.start();

			stIN = new BufferedReader(new InputStreamReader(System.in));
			while((line = stIN.readLine()) != null)
			{
				out.println(line);
				out.flush();
			}


		}
		catch(IOException ioe)
		{System.out.println("Fehler beim verbinden zum Server.");}

	}


	public void processLine(String line)
	{
		System.out.println("##:" +line);
	}

	public void endConnection(int id)
	{
		System.out.println("Verbindung zum Server verloren...");
	}
}
-CListener-
Code:
import java.io.*;
import java.net.*;

public class CListener implements Runnable
{
	private BufferedReader in;
	private Socket clientSock;
	private IListenAble obj;
	private int id;

	CListener(Socket clientSock, IListenAble obj, int id) throws IOException
	{
		this.in = new BufferedReader(new InputStreamReader(clientSock.getInputStream()));
		this.clientSock = clientSock;
		this.obj = obj;
		this.id = id;
	}

	public void run()
	{
		String line;
		try
		{
			while((line = in.readLine()) != null)
			{
				this.obj.processLine(line);
			}
		}
		catch(IOException ioe)
		{}
		this.obj.endConnection(this.id);
	}
}
-IListenAble-
Code:
public interface IListenAble
{
	public void processLine(String line);
	public void endConnection(int Id);
}
Jedes Bit dieses Codes ist frei.Es darf tuen was es will und wann es will. Sollte ein Bit Fehlerhaft sein so bitte ich es es mir zu sagen. Sollte ein Bit so fehlerhaft sein das es mir nicht mehr sagen kann das es fehlerhaft ist so bitte ich die nachbarBits mir von dem Fehler zu berichten.