Strafkolonie Online

107 145 156 141 165 040 107 141 162 162 145 164 056 040 123 160 141 155 040 155 165 163 163 040 163 145 151 156 056 040 110 141 142 040 163 143 150 157 156 040 156 151 143 150 164 040 142 145 151 040 144 145 155 040 125 163 145 162 156 141 155 145 040 115 151 163 164 040 155 151 164 147 145 155 141 143 150 164 056 040 104 141 040 155 165 163 163 040 151 143 150 040 150 141 154 164 040 155 141 154 040 167 157 141 156 144 145 162 163 040 163 143 150 303 266 156 040 163 160 141 155 155 155 145 156 056

Das kann ich auch xD:

namespace Server
{
class Server
{

private static byte[] _buffer = new byte[1024];
private static Socket _serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
private static List<Socket> _clientSockets = new List<Socket>();
private DatabaseConnector con = new DatabaseConnector();


static void Main()
{
SetupServer();

Console.ReadLine();
}

private static void SetupServer() //setting up the Server and starting to accept connections
{
Console.WriteLine("Seting up Server");
IPEndPoint EP = new IPEndPoint(IPAddress.Any, 100);
_serverSocket.Bind(EP);
_serverSocket.Listen(1);
_serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), null);


}

private static void AcceptCallback(IAsyncResult AR) //Accepting the Connections from the Clients and adding them to the Clientsockets list
{
Socket socket = _serverSocket.EndAccept(AR);

_clientSockets.Add(socket);
Console.WriteLine("Client connect");
socket.BeginReceive(_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), socket);
_serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), null);


}
private void ReceiveCallback(IAsyncResult AR)
{
Socket socket = (Socket)AR.AsyncState;
int received = socket.EndReceive(AR);
byte[] dataBuffer = new byte[received];
Array.Copy(_buffer, dataBuffer, received);
string[] text =Regex.Split( Encoding.ASCII.GetString(dataBuffer),";");
Console.WriteLine("Text Received: " + text[0]);



string response = string.Empty;

if (text[0]=="1") //Login
{

string username= text[1];
string password=text[2];
bool registered=this.con.checkCredentials(username,password);
if (registered)
{

this.con.setLoggedOn(username);
response = "3;true";
}
else
{
response = "3;false";
}
byte[] data = Encoding.ASCII.GetBytes(response);
send(data,socket);

}
else if (text[0]=="3") //Register
{

this.con.addUser(username, password);
bool registered=this.con.checkCredentials(username,password);
if (registered){
response="3;true";
}
else {
response="3;false";
}

byte[] data = Encoding.ASCII.GetBytes(response);
send(data,socket);

}
else if (text[0] == "4") //Logout
{
this.con.setLoggedOut(text[1]);
response="3;true";

byte[] data = Encoding.ASCII.GetBytes(response);
send(data, socket);

}
else //Send Message
{
this.con.logMessage(text[1],text[2]);
response = text[1]+";"+text[2]+";"+6;

byte[] data = Encoding.ASCII.GetBytes(response);
sendToAll(data);
}

socket.BeginReceive(_buffer, 0, _buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), socket);

}
private static void send(byte[] data, Socket socket) //The Method for Sending data to the Client with the specific Socket
{
socket.BeginSend(data, 0, data.Length, SocketFlags.None, new AsyncCallback(SendCallback), socket);
}
private static void sendToAll(byte[] data) //The Method for sending the essage to all Clients that are contained in the socketslist.
{
for (int i = 0; i < _clientSockets.Count; i++)
{
send(data, _clientSockets);


}
}
private static void SendCallback(IAsyncResult AR)
{
Socket socket = (Socket)AR.AsyncState;
socket.EndSend(AR);
}
}
}