Contents

Features

Requirements

How to build?

Setup repository

git clone https://github.com/chronoxor/NetCoreServer.gitcd NetCoreServer

Linux

cd build./unix.sh

MacOS

cd build./unix.sh

Windows (Visual Studio)

cd buildvs.bat

Examples

Example: TCP chat server

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Text;usingNetCoreServer;namespaceTcpChatServer{classChatSession:TcpSession{publicChatSession(TcpServerserver):base(server){}protectedoverridevoidOnConnected(){Console.WriteLine($"Chat TCP session with Id{Id} connected!");// Send invite messagestringmessage="Hello from TCP chat! Please send a message or '!' to disconnect the client!";SendAsync(message);}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Chat TCP session with Id{Id} disconnected!");}protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){stringmessage=Encoding.UTF8.GetString(buffer,(int)offset,(int)size);Console.WriteLine("Incoming: "+message);// Multicast message to all connected sessionsServer.Multicast(message);// If the buffer starts with '!' the disconnect the current sessionif(message=="!")Disconnect();}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat TCP session caught an error with code{error}");}}classChatServer:TcpServer{publicChatServer(IPAddressaddress,intport):base(address,port){}protectedoverrideTcpSessionCreateSession(){returnnewChatSession(this);}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat TCP server caught an error with code{error}");}}classProgram{staticvoidMain(string[]args){// TCP server portintport=1111;if(args.Length>0)port=int.Parse(args[0]);Console.WriteLine($"TCP server port:{port}");Console.WriteLine();// Create a new TCP chat servervarserver=newChatServer(IPAddress.Any,port);// Start the serverConsole.Write("Server starting...");server.Start();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Restart the serverif(line=="!"){Console.Write("Server restarting...");server.Restart();Console.WriteLine("Done!");continue;}// Multicast admin message to all sessionsline="(admin) "+line;server.Multicast(line);}// Stop the serverConsole.Write("Server stopping...");server.Stop();Console.WriteLine("Done!");}}}

Example: TCP chat client

usingSystem;usingSystem.Net.Sockets;usingSystem.Text;usingSystem.Threading;usingTcpClient=NetCoreServer.TcpClient;namespaceTcpChatClient{classChatClient:TcpClient{publicChatClient(stringaddress,intport):base(address,port){}publicvoidDisconnectAndStop(){_stop=true;DisconnectAsync();while(IsConnected)Thread.Yield();}protectedoverridevoidOnConnected(){Console.WriteLine($"Chat TCP client connected a new session with Id{Id}");}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Chat TCP client disconnected a session with Id{Id}");// Wait for a while...Thread.Sleep(1000);// Try to connect againif(!_stop)ConnectAsync();}protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){Console.WriteLine(Encoding.UTF8.GetString(buffer,(int)offset,(int)size));}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat TCP client caught an error with code{error}");}privatebool_stop;}classProgram{staticvoidMain(string[]args){// TCP server addressstringaddress="127.0.0.1";if(args.Length>0)address=args[0];// TCP server portintport=1111;if(args.Length>1)port=int.Parse(args[1]);Console.WriteLine($"TCP server address:{address}");Console.WriteLine($"TCP server port:{port}");Console.WriteLine();// Create a new TCP chat clientvarclient=newChatClient(address,port);// Connect the clientConsole.Write("Client connecting...");client.ConnectAsync();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the client or '!' to reconnect the client...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Disconnect the clientif(line=="!"){Console.Write("Client disconnecting...");client.DisconnectAsync();Console.WriteLine("Done!");continue;}// Send the entered text to the chat serverclient.SendAsync(line);}// Disconnect the clientConsole.Write("Client disconnecting...");client.DisconnectAndStop();Console.WriteLine("Done!");}}}

Example: SSL chat server

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Security.Authentication;usingSystem.Security.Cryptography.X509Certificates;usingSystem.Text;usingNetCoreServer;namespaceSslChatServer{classChatSession:SslSession{publicChatSession(SslServerserver):base(server){}protectedoverridevoidOnConnected(){Console.WriteLine($"Chat SSL session with Id{Id} connected!");}protectedoverridevoidOnHandshaked(){Console.WriteLine($"Chat SSL session with Id{Id} handshaked!");// Send invite messagestringmessage="Hello from SSL chat! Please send a message or '!' to disconnect the client!";Send(message);}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Chat SSL session with Id{Id} disconnected!");}protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){stringmessage=Encoding.UTF8.GetString(buffer,(int)offset,(int)size);Console.WriteLine("Incoming: "+message);// Multicast message to all connected sessionsServer.Multicast(message);// If the buffer starts with '!' the disconnect the current sessionif(message=="!")Disconnect();}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat SSL session caught an error with code{error}");}}classChatServer:SslServer{publicChatServer(SslContextcontext,IPAddressaddress,intport):base(context,address,port){}protectedoverrideSslSessionCreateSession(){returnnewChatSession(this);}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat SSL server caught an error with code{error}");}}classProgram{staticvoidMain(string[]args){// SSL server portintport=2222;if(args.Length>0)port=int.Parse(args[0]);Console.WriteLine($"SSL server port:{port}");Console.WriteLine();// Create and prepare a new SSL server contextvarcontext=newSslContext(SslProtocols.Tls12,newX509Certificate2("server.pfx","qwerty"));// Create a new SSL chat servervarserver=newChatServer(context,IPAddress.Any,port);// Start the serverConsole.Write("Server starting...");server.Start();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Restart the serverif(line=="!"){Console.Write("Server restarting...");server.Restart();Console.WriteLine("Done!");continue;}// Multicast admin message to all sessionsline="(admin) "+line;server.Multicast(line);}// Stop the serverConsole.Write("Server stopping...");server.Stop();Console.WriteLine("Done!");}}}

Example: SSL chat client

usingSystem;usingSystem.Net.Sockets;usingSystem.Security.Authentication;usingSystem.Security.Cryptography.X509Certificates;usingSystem.Text;usingSystem.Threading;usingNetCoreServer;namespaceSslChatClient{classChatClient:SslClient{publicChatClient(SslContextcontext,stringaddress,intport):base(context,address,port){}publicvoidDisconnectAndStop(){_stop=true;DisconnectAsync();while(IsConnected)Thread.Yield();}protectedoverridevoidOnConnected(){Console.WriteLine($"Chat SSL client connected a new session with Id{Id}");}protectedoverridevoidOnHandshaked(){Console.WriteLine($"Chat SSL client handshaked a new session with Id{Id}");}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Chat SSL client disconnected a session with Id{Id}");// Wait for a while...Thread.Sleep(1000);// Try to connect againif(!_stop)ConnectAsync();}protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){Console.WriteLine(Encoding.UTF8.GetString(buffer,(int)offset,(int)size));}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat SSL client caught an error with code{error}");}privatebool_stop;}classProgram{staticvoidMain(string[]args){// SSL server addressstringaddress="127.0.0.1";if(args.Length>0)address=args[0];// SSL server portintport=2222;if(args.Length>1)port=int.Parse(args[1]);Console.WriteLine($"SSL server address:{address}");Console.WriteLine($"SSL server port:{port}");Console.WriteLine();// Create and prepare a new SSL client contextvarcontext=newSslContext(SslProtocols.Tls12,newX509Certificate2("client.pfx","qwerty"),(sender,certificate,chain,sslPolicyErrors)=>true);// Create a new SSL chat clientvarclient=newChatClient(context,address,port);// Connect the clientConsole.Write("Client connecting...");client.ConnectAsync();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the client or '!' to reconnect the client...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Disconnect the clientif(line=="!"){Console.Write("Client disconnecting...");client.DisconnectAsync();Console.WriteLine("Done!");continue;}// Send the entered text to the chat serverclient.SendAsync(line);}// Disconnect the clientConsole.Write("Client disconnecting...");client.DisconnectAndStop();Console.WriteLine("Done!");}}}

Example: UDP echo server

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Text;usingNetCoreServer;namespaceUdpEchoServer{classEchoServer:UdpServer{publicEchoServer(IPAddressaddress,intport):base(address,port){}protectedoverridevoidOnStarted(){// Start receive datagramsReceiveAsync();}protectedoverridevoidOnReceived(EndPointendpoint,byte[]buffer,longoffset,longsize){Console.WriteLine("Incoming: "+Encoding.UTF8.GetString(buffer,(int)offset,(int)size));// Echo the message back to the senderSendAsync(endpoint,buffer,0,size);}protectedoverridevoidOnSent(EndPointendpoint,longsent){// Continue receive datagramsReceiveAsync();}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Echo UDP server caught an error with code{error}");}}classProgram{staticvoidMain(string[]args){// UDP server portintport=3333;if(args.Length>0)port=int.Parse(args[0]);Console.WriteLine($"UDP server port:{port}");Console.WriteLine();// Create a new UDP echo servervarserver=newEchoServer(IPAddress.Any,port);// Start the serverConsole.Write("Server starting...");server.Start();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Restart the serverif(line=="!"){Console.Write("Server restarting...");server.Restart();Console.WriteLine("Done!");}}// Stop the serverConsole.Write("Server stopping...");server.Stop();Console.WriteLine("Done!");}}}

Example: UDP echo client

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Text;usingSystem.Threading;usingUdpClient=NetCoreServer.UdpClient;namespaceUdpEchoClient{classEchoClient:UdpClient{publicEchoClient(stringaddress,intport):base(address,port){}publicvoidDisconnectAndStop(){_stop=true;Disconnect();while(IsConnected)Thread.Yield();}protectedoverridevoidOnConnected(){Console.WriteLine($"Echo UDP client connected a new session with Id{Id}");// Start receive datagramsReceiveAsync();}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Echo UDP client disconnected a session with Id{Id}");// Wait for a while...Thread.Sleep(1000);// Try to connect againif(!_stop)Connect();}protectedoverridevoidOnReceived(EndPointendpoint,byte[]buffer,longoffset,longsize){Console.WriteLine("Incoming: "+Encoding.UTF8.GetString(buffer,(int)offset,(int)size));// Continue receive datagramsReceiveAsync();}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Echo UDP client caught an error with code{error}");}privatebool_stop;}classProgram{staticvoidMain(string[]args){// UDP server addressstringaddress="127.0.0.1";if(args.Length>0)address=args[0];// UDP server portintport=3333;if(args.Length>1)port=int.Parse(args[1]);Console.WriteLine($"UDP server address:{address}");Console.WriteLine($"UDP server port:{port}");Console.WriteLine();// Create a new TCP chat clientvarclient=newEchoClient(address,port);// Connect the clientConsole.Write("Client connecting...");client.Connect();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the client or '!' to reconnect the client...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Disconnect the clientif(line=="!"){Console.Write("Client disconnecting...");client.Disconnect();Console.WriteLine("Done!");continue;}// Send the entered text to the chat serverclient.Send(line);}// Disconnect the clientConsole.Write("Client disconnecting...");client.DisconnectAndStop();Console.WriteLine("Done!");}}}

Example: UDP multicast server

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingNetCoreServer;namespaceUdpMulticastServer{classMulticastServer:UdpServer{publicMulticastServer(IPAddressaddress,intport):base(address,port){}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Multicast UDP server caught an error with code{error}");}}classProgram{staticvoidMain(string[]args){// UDP multicast addressstringmulticastAddress="239.255.0.1";if(args.Length>0)multicastAddress=args[0];// UDP multicast portintmulticastPort=3334;if(args.Length>1)multicastPort=int.Parse(args[1]);Console.WriteLine($"UDP multicast address:{multicastAddress}");Console.WriteLine($"UDP multicast port:{multicastPort}");Console.WriteLine();// Create a new UDP multicast servervarserver=newMulticastServer(IPAddress.Any,0);// Start the multicast serverConsole.Write("Server starting...");server.Start(multicastAddress,multicastPort);Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Restart the serverif(line=="!"){Console.Write("Server restarting...");server.Restart();Console.WriteLine("Done!");continue;}// Multicast admin message to all sessionsline="(admin) "+line;server.Multicast(line);}// Stop the serverConsole.Write("Server stopping...");server.Stop();Console.WriteLine("Done!");}}}

Example: UDP multicast client

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Text;usingSystem.Threading;usingUdpClient=NetCoreServer.UdpClient;namespaceUdpMulticastClient{classMulticastClient:UdpClient{publicstringMulticast;publicMulticastClient(stringaddress,intport):base(address,port){}publicvoidDisconnectAndStop(){_stop=true;Disconnect();while(IsConnected)Thread.Yield();}protectedoverridevoidOnConnected(){Console.WriteLine($"Multicast UDP client connected a new session with Id{Id}");// Join UDP multicast groupJoinMulticastGroup(Multicast);// Start receive datagramsReceiveAsync();}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Multicast UDP client disconnected a session with Id{Id}");// Wait for a while...Thread.Sleep(1000);// Try to connect againif(!_stop)Connect();}protectedoverridevoidOnReceived(EndPointendpoint,byte[]buffer,longoffset,longsize){Console.WriteLine("Incoming: "+Encoding.UTF8.GetString(buffer,(int)offset,(int)size));// Continue receive datagramsReceiveAsync();}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Multicast UDP client caught an error with code{error}");}privatebool_stop;}classProgram{staticvoidMain(string[]args){// UDP listen addressstringlistenAddress="0.0.0.0";if(args.Length>0)listenAddress=args[0];// UDP multicast addressstringmulticastAddress="239.255.0.1";if(args.Length>1)multicastAddress=args[1];// UDP multicast portintmulticastPort=3334;if(args.Length>2)multicastPort=int.Parse(args[2]);Console.WriteLine($"UDP listen address:{listenAddress}");Console.WriteLine($"UDP multicast address:{multicastAddress}");Console.WriteLine($"UDP multicast port:{multicastPort}");Console.WriteLine();// Create a new TCP chat clientvarclient=newMulticastClient(listenAddress,multicastPort);client.SetupMulticast(true);client.Multicast=multicastAddress;// Connect the clientConsole.Write("Client connecting...");client.Connect();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the client or '!' to reconnect the client...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Disconnect the clientif(line=="!"){Console.Write("Client disconnecting...");client.Disconnect();Console.WriteLine("Done!");continue;}}// Disconnect the clientConsole.Write("Client disconnecting...");client.DisconnectAndStop();Console.WriteLine("Done!");}}}

Example: Unix Domain Socket chat server

usingSystem;usingSystem.IO;usingSystem.Net.Sockets;usingSystem.Text;usingNetCoreServer;namespaceUdsChatServer{classChatSession:UdsSession{publicChatSession(UdsServerserver):base(server){}protectedoverridevoidOnConnected(){Console.WriteLine($"Chat Unix Domain Socket session with Id{Id} connected!");// Send invite messagestringmessage="Hello from Unix Domain Socket chat! Please send a message or '!' to disconnect the client!";SendAsync(message);}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Chat Unix Domain Socket session with Id{Id} disconnected!");}protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){stringmessage=Encoding.UTF8.GetString(buffer,(int)offset,(int)size);Console.WriteLine("Incoming: "+message);// Multicast message to all connected sessionsServer.Multicast(message);// If the buffer starts with '!' the disconnect the current sessionif(message=="!")Disconnect();}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat Unix Domain Socket session caught an error with code{error}");}}classChatServer:UdsServer{publicChatServer(stringpath):base(path){}protectedoverrideUdsSessionCreateSession(){returnnewChatSession(this);}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat Unix Domain Socket server caught an error with code{error}");}}classProgram{staticvoidMain(string[]args){// Unix Domain Socket pathstringpath=Path.Combine(Path.GetTempPath(),"chat.sock");if(args.Length>0)path=args[0];Console.WriteLine($"Unix Domain Socket server path:{path}");Console.WriteLine();// Create a new Unix Domain Socket chat servervarserver=newChatServer(path);// Start the serverConsole.Write("Server starting...");server.Start();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Restart the serverif(line=="!"){Console.Write("Server restarting...");server.Restart();Console.WriteLine("Done!");continue;}// Multicast admin message to all sessionsline="(admin) "+line;server.Multicast(line);}// Stop the serverConsole.Write("Server stopping...");server.Stop();Console.WriteLine("Done!");}}}

Example: Unix Domain Socket chat client

usingSystem;usingSystem.IO;usingSystem.Net.Sockets;usingSystem.Text;usingSystem.Threading;usingUdsClient=NetCoreServer.UdsClient;namespaceUdsChatClient{classChatClient:UdsClient{publicChatClient(stringpath):base(path){}publicvoidDisconnectAndStop(){_stop=true;DisconnectAsync();while(IsConnected)Thread.Yield();}protectedoverridevoidOnConnected(){Console.WriteLine($"Chat Unix Domain Socket client connected a new session with Id{Id}");}protectedoverridevoidOnDisconnected(){Console.WriteLine($"Chat Unix Domain Socket client disconnected a session with Id{Id}");// Wait for a while...Thread.Sleep(1000);// Try to connect againif(!_stop)ConnectAsync();}protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){Console.WriteLine(Encoding.UTF8.GetString(buffer,(int)offset,(int)size));}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Chat Unix Domain Socket client caught an error with code{error}");}privatebool_stop;}classProgram{staticvoidMain(string[]args){// Unix Domain Socket pathstringpath=Path.Combine(Path.GetTempPath(),"chat.sock");if(args.Length>0)path=args[0];Console.WriteLine($"Unix Domain Socket server path:{path}");Console.WriteLine();// Create a new Unix Domain Socket chat clientvarclient=newChatClient(path);// Connect the clientConsole.Write("Client connecting...");client.ConnectAsync();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the client or '!' to reconnect the client...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Disconnect the clientif(line=="!"){Console.Write("Client disconnecting...");client.DisconnectAsync();Console.WriteLine("Done!");continue;}// Send the entered text to the chat serverclient.SendAsync(line);}// Disconnect the clientConsole.Write("Client disconnecting...");client.DisconnectAndStop();Console.WriteLine("Done!");}}}

Example: Simple protocol

/*   Simple Fast Binary Encoding protocol for CppServer   https://github.com/chronoxor/FastBinaryEncoding   Generate protocol command: fbec --csharp --proto --input=simple.fbe --output=.*/// Domain declarationdomain com.chronoxor// Package declarationpackage simple// Protocol versionversion 1.0// Simple request message[request][response(SimpleResponse)][reject(SimpleReject)]messageSimpleRequest{// Request Id    uuid [id] = uuid1;// Request message    string Message;}// Simple responsemessageSimpleResponse{// Response Id    uuid [id] = uuid1;// Calculated message length    uint32 Length;// Calculated message hash    uint32 Hash;}// Simple rejectmessageSimpleReject{// Reject Id    uuid [id] = uuid1;// Error message    string Error;}// Simple notificationmessageSimpleNotify{// Server notification    string Notification;}// Disconnect request message[request]messageDisconnectRequest{// Request Id    uuid [id] = uuid1;}

Example: Simple protocol server

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingNetCoreServer;usingcom.chronoxor.simple;usingcom.chronoxor.simple.FBE;namespaceProtoServer{publicclassSimpleProtoSessionSender:Sender,ISenderListener{publicSimpleProtoSessionSession{get;}publicSimpleProtoSessionSender(SimpleProtoSessionsession){Session=session;}publiclongOnSend(byte[]buffer,longoffset,longsize){returnSession.SendAsync(buffer,offset,size)?size:0;}}publicclassSimpleProtoSessionReceiver:Receiver,IReceiverListener{publicSimpleProtoSessionSession{get;}publicSimpleProtoSessionReceiver(SimpleProtoSessionsession){Session=session;}publicvoidOnReceive(DisconnectRequestrequest){Session.OnReceive(request);}publicvoidOnReceive(SimpleRequestrequest){Session.OnReceive(request);}}publicclassSimpleProtoSession:TcpSession{publicSimpleProtoSessionSenderSender{get;}publicSimpleProtoSessionReceiverReceiver{get;}publicSimpleProtoSession(TcpServerserver):base(server){Sender=newSimpleProtoSessionSender(this);Receiver=newSimpleProtoSessionReceiver(this);}protectedoverridevoidOnConnected(){Console.WriteLine($"TCP protocol session with Id '{Id}' connected to remote address '{(Socket.RemoteEndPointasIPEndPoint)?.Address}' and port{(Socket.RemoteEndPointasIPEndPoint)?.Port}");// Send invite notificationSimpleNotifynotify=SimpleNotify.Default;notify.Notification="Hello from Simple protocol server! Please send a message or '!' to disconnect the client!";Sender.Send(notify);}protectedoverridevoidOnDisconnected(){Console.WriteLine($"TCP protocol session with Id '{Id}' disconnected");}protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){Receiver.Receive(buffer,offset,size);}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"TCP protocol session with Id '{Id}' caught a socket error:{error}");}// Protocol handlerspublicvoidOnReceive(DisconnectRequestrequest){Disconnect();}publicvoidOnReceive(SimpleRequestrequest){Console.WriteLine($"Received:{request}");// Validate requestif(string.IsNullOrEmpty(request.Message)){// Send rejectSimpleRejectreject=SimpleReject.Default;reject.id=request.id;reject.Error="Request message is empty!";Sender.Send(reject);return;}// Send responseSimpleResponseresponse=SimpleResponse.Default;response.id=request.id;response.Hash=(uint)request.Message.GetHashCode();response.Length=(uint)request.Message.Length;Sender.Send(response);}}publicclassSimpleProtoSender:Sender,ISenderListener{publicSimpleProtoServerServer{get;}publicSimpleProtoSender(SimpleProtoServerserver){Server=server;}publiclongOnSend(byte[]buffer,longoffset,longsize){Server.Multicast(buffer,offset,size);returnsize;}}publicclassSimpleProtoServer:TcpServer{publicSimpleProtoSenderSender{get;}publicSimpleProtoServer(IPAddressaddress,intport):base(address,port){Sender=newSimpleProtoSender(this);}protectedoverrideTcpSessionCreateSession(){returnnewSimpleProtoSession(this);}protectedoverridevoidOnStarted(){Console.WriteLine($"Simple protocol server with Id '{Id}' started!");}protectedoverridevoidOnStopped(){Console.WriteLine($"Simple protocol server with Id '{Id}' stopped!");}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"Simple protocol server with Id '{Id}' caught an error:{error}");}}classProgram{staticvoidMain(string[]args){// Simple protocol server portintport=4444;if(args.Length>0)port=int.Parse(args[0]);Console.WriteLine($"Simple protocol server port:{port}");Console.WriteLine();// Create a new simple protocol servervarserver=newSimpleProtoServer(IPAddress.Any,port);// Start the serverConsole.Write("Server starting...");server.Start();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Restart the serverif(line=="!"){Console.Write("Server restarting...");server.Restart();Console.WriteLine("Done!");continue;}// Multicast admin notification to all sessionsSimpleNotifynotify=SimpleNotify.Default;notify.Notification="(admin) "+line;server.Sender.Send(notify);}// Stop the serverConsole.Write("Server stopping...");server.Stop();Console.WriteLine("Done!");}}}

Example: Simple protocol client

usingSystem;usingSystem.Net.Sockets;usingSystem.Threading;usingTcpClient=NetCoreServer.TcpClient;usingcom.chronoxor.simple;usingcom.chronoxor.simple.FBE;namespaceProtoClient{publicclassTcpProtoClient:TcpClient{publicTcpProtoClient(stringaddress,intport):base(address,port){}publicboolConnectAndStart(){Console.WriteLine($"TCP protocol client starting a new session with Id '{Id}'...");StartReconnectTimer();returnConnectAsync();}publicboolDisconnectAndStop(){Console.WriteLine($"TCP protocol client stopping the session with Id '{Id}'...");StopReconnectTimer();DisconnectAsync();returntrue;}publicoverrideboolReconnect(){returnReconnectAsync();}privateTimer_reconnectTimer;publicvoidStartReconnectTimer(){// Start the reconnect timer_reconnectTimer=newTimer(state=>{Console.WriteLine($"TCP reconnect timer connecting the client session with Id '{Id}'...");ConnectAsync();},null,Timeout.InfiniteTimeSpan,Timeout.InfiniteTimeSpan);}publicvoidStopReconnectTimer(){// Stop the reconnect timer_reconnectTimer?.Dispose();_reconnectTimer=null;}publicdelegatevoidConnectedHandler();publiceventConnectedHandlerConnected=()=>{};protectedoverridevoidOnConnected(){Console.WriteLine($"TCP protocol client connected a new session with Id '{Id}' to remote address '{Address}' and port{Port}");Connected?.Invoke();}publicdelegatevoidDisconnectedHandler();publiceventDisconnectedHandlerDisconnected=()=>{};protectedoverridevoidOnDisconnected(){Console.WriteLine($"TCP protocol client disconnected the session with Id '{Id}'");// Setup and asynchronously wait for the reconnect timer_reconnectTimer?.Change(TimeSpan.FromSeconds(1),Timeout.InfiniteTimeSpan);Disconnected?.Invoke();}publicdelegatevoidReceivedHandler(byte[]buffer,longoffset,longsize);publiceventReceivedHandlerReceived=(buffer,offset,size)=>{};protectedoverridevoidOnReceived(byte[]buffer,longoffset,longsize){Received?.Invoke(buffer,offset,size);}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"TCP protocol client caught a socket error:{error}");}        #region IDisposable implementation// Disposed flag.privatebool_disposed;protectedoverridevoidDispose(booldisposingManagedResources){if(!_disposed){if(disposingManagedResources){// Dispose managed resources here...StopReconnectTimer();}// Dispose unmanaged resources here...// Set large fields to null here...// Mark as disposed._disposed=true;}// Call Dispose in the base class.base.Dispose(disposingManagedResources);}// The derived class does not have a Finalize method// or a Dispose method without parameters because it inherits// them from the base class.        #endregion}publicclassSimpleProtoClient:Client,ISenderListener,IReceiverListener,IDisposable{privatereadonlyTcpProtoClient_tcpProtoClient;publicGuidId=>_tcpProtoClient.Id;publicboolIsConnected=>_tcpProtoClient.IsConnected;publicSimpleProtoClient(stringaddress,intport){_tcpProtoClient=newTcpProtoClient(address,port);_tcpProtoClient.Connected+=OnConnected;_tcpProtoClient.Disconnected+=OnDisconnected;_tcpProtoClient.Received+=OnReceived;ReceivedResponse_DisconnectRequest+=HandleDisconnectRequest;ReceivedResponse_SimpleResponse+=HandleSimpleResponse;ReceivedResponse_SimpleReject+=HandleSimpleReject;ReceivedResponse_SimpleNotify+=HandleSimpleNotify;}privatevoidDisposeClient(){_tcpProtoClient.Connected-=OnConnected;_tcpProtoClient.Connected-=OnDisconnected;_tcpProtoClient.Received-=OnReceived;ReceivedResponse_DisconnectRequest-=HandleDisconnectRequest;ReceivedResponse_SimpleResponse-=HandleSimpleResponse;ReceivedResponse_SimpleReject-=HandleSimpleReject;ReceivedResponse_SimpleNotify-=HandleSimpleNotify;_tcpProtoClient.Dispose();}publicboolConnectAndStart(){return_tcpProtoClient.ConnectAndStart();}publicboolDisconnectAndStop(){return_tcpProtoClient.DisconnectAndStop();}publicboolReconnect(){return_tcpProtoClient.Reconnect();}privatebool_watchdog;privateThread_watchdogThread;publicboolStartWatchdog(){if(_watchdog)returnfalse;Console.WriteLine("Watchdog thread starting...");// Start the watchdog thread_watchdog=true;_watchdogThread=newThread(WatchdogThread);Console.WriteLine("Watchdog thread started!");returntrue;}publicboolStopWatchdog(){if(!_watchdog)returnfalse;Console.WriteLine("Watchdog thread stopping...");// Stop the watchdog thread_watchdog=false;_watchdogThread.Join();Console.WriteLine("Watchdog thread stopped!");returntrue;}publicstaticvoidWatchdogThread(objectobj){varinstance=objasSimpleProtoClient;if(instance==null)return;try{// Watchdog loop...while(instance._watchdog){varutc=DateTime.UtcNow;// Watchdog the clientinstance.Watchdog(utc);// Sleep for a while...Thread.Sleep(1000);}}catch(Exceptione){Console.WriteLine($"Config client watchdog thread terminated:{e}");}}        #region Connection handlerspublicdelegatevoidConnectedHandler();publiceventConnectedHandlerConnected=()=>{};privatevoidOnConnected(){// Reset FBE protocol buffersReset();Connected?.Invoke();}publicdelegatevoidDisconnectedHandler();publiceventDisconnectedHandlerDisconnected=()=>{};privatevoidOnDisconnected(){Disconnected?.Invoke();}publiclongOnSend(byte[]buffer,longoffset,longsize){return_tcpProtoClient.SendAsync(buffer,offset,size)?size:0;}publicvoidOnReceived(byte[]buffer,longoffset,longsize){Receive(buffer,offset,size);}        #endregion        #region Protocol handlersprivatevoidHandleDisconnectRequest(DisconnectRequestrequest){Console.WriteLine($"Received:{request}");_tcpProtoClient.DisconnectAsync();}privatevoidHandleSimpleResponse(SimpleResponseresponse){Console.WriteLine($"Received:{response}");}privatevoidHandleSimpleReject(SimpleRejectreject){Console.WriteLine($"Received:{reject}");}privatevoidHandleSimpleNotify(SimpleNotifynotify){Console.WriteLine($"Received:{notify}");}        #endregion        #region IDisposable implementation// Disposed flag.privatebool_disposed;// Implement IDisposable.publicvoidDispose(){Dispose(true);GC.SuppressFinalize(this);}protectedvirtualvoidDispose(booldisposingManagedResources){// The idea here is that Dispose(Boolean) knows whether it is// being called to do explicit cleanup (the Boolean is true)// versus being called due to a garbage collection (the Boolean// is false). This distinction is useful because, when being// disposed explicitly, the Dispose(Boolean) method can safely// execute code using reference type fields that refer to other// objects knowing for sure that these other objects have not been// finalized or disposed of yet. When the Boolean is false,// the Dispose(Boolean) method should not execute code that// refer to reference type fields because those objects may// have already been finalized."if(!_disposed){if(disposingManagedResources){// Dispose managed resources here...DisposeClient();}// Dispose unmanaged resources here...// Set large fields to null here...// Mark as disposed._disposed=true;}}        #endregion}classProgram{staticvoidMain(string[]args){// Simple protocol server addressstringaddress="127.0.0.1";if(args.Length>0)address=args[0];// Simple protocol server portintport=4444;if(args.Length>1)port=int.Parse(args[1]);Console.WriteLine($"Simple protocol server address:{address}");Console.WriteLine($"Simple protocol server port:{port}");Console.WriteLine();// Create a new simple protocol chat clientvarclient=newSimpleProtoClient(address,port);// Connect the clientConsole.Write("Client connecting...");client.ConnectAndStart();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the client or '!' to reconnect the client...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Disconnect the clientif(line=="!"){Console.Write("Client disconnecting...");client.Reconnect();Console.WriteLine("Done!");continue;}// Send request to the simple protocol serverSimpleRequestrequest=SimpleRequest.Default;request.Message=line;varresponse=client.Request(request).Result;// Show string hash calculation resultConsole.WriteLine($"Hash of '{line}' = 0x{response.Hash:X8}");}// Disconnect the clientConsole.Write("Client disconnecting...");client.DisconnectAndStop();Console.WriteLine("Done!");}}}

Example: HTTP server

usingSystem;usingSystem.Collections.Concurrent;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Text;usingNetCoreServer;namespaceHttpServer{classCommonCache{publicstaticCommonCacheGetInstance(){if(_instance==null)_instance=newCommonCache();return_instance;}publicstringGetAllCache(){varresult=newStringBuilder();result.Append("[\n");foreach(varitemin_cache){result.Append("  {\n");result.AppendFormat($"\"key\":\"{item.Key}\",\n");result.AppendFormat($"\"value\":\"{item.Value}\",\n");result.Append("  },\n");}result.Append("]\n");returnresult.ToString();}publicboolGetCacheValue(stringkey,outstringvalue){return_cache.TryGetValue(key,outvalue);}publicvoidPutCacheValue(stringkey,stringvalue){_cache[key]=value;}publicboolDeleteCacheValue(stringkey,outstringvalue){return_cache.TryRemove(key,outvalue);}privatereadonlyConcurrentDictionary<string,string>_cache=newConcurrentDictionary<string,string>();privatestaticCommonCache_instance;}classHttpCacheSession:HttpSession{publicHttpCacheSession(NetCoreServer.HttpServerserver):base(server){}protectedoverridevoidOnReceivedRequest(HttpRequestrequest){// Show HTTP request contentConsole.WriteLine(request);// Process HTTP request methodsif(request.Method=="HEAD")SendResponseAsync(Response.MakeHeadResponse());elseif(request.Method=="GET"){stringkey=request.Url;// Decode the key valuekey=Uri.UnescapeDataString(key);key=key.Replace("/api/cache","",StringComparison.InvariantCultureIgnoreCase);key=key.Replace("?key=","",StringComparison.InvariantCultureIgnoreCase);if(string.IsNullOrEmpty(key)){// Response with all cache valuesSendResponseAsync(Response.MakeGetResponse(CommonCache.GetInstance().GetAllCache(),"application/json; charset=UTF-8"));}// Get the cache value by the given keyelseif(CommonCache.GetInstance().GetCacheValue(key,outvarvalue)){// Response with the cache valueSendResponseAsync(Response.MakeGetResponse(value));}elseSendResponseAsync(Response.MakeErrorResponse(404,"Required cache value was not found for the key: "+key));}elseif((request.Method=="POST")||(request.Method=="PUT")){stringkey=request.Url;stringvalue=request.Body;// Decode the key valuekey=Uri.UnescapeDataString(key);key=key.Replace("/api/cache","",StringComparison.InvariantCultureIgnoreCase);key=key.Replace("?key=","",StringComparison.InvariantCultureIgnoreCase);// Put the cache valueCommonCache.GetInstance().PutCacheValue(key,value);// Response with the cache valueSendResponseAsync(Response.MakeOkResponse());}elseif(request.Method=="DELETE"){stringkey=request.Url;// Decode the key valuekey=Uri.UnescapeDataString(key);key=key.Replace("/api/cache","",StringComparison.InvariantCultureIgnoreCase);key=key.Replace("?key=","",StringComparison.InvariantCultureIgnoreCase);// Delete the cache valueif(CommonCache.GetInstance().DeleteCacheValue(key,outvarvalue)){// Response with the cache valueSendResponseAsync(Response.MakeGetResponse(value));}elseSendResponseAsync(Response.MakeErrorResponse(404,"Deleted cache value was not found for the key: "+key));}elseif(request.Method=="OPTIONS")SendResponseAsync(Response.MakeOptionsResponse());elseif(request.Method=="TRACE")SendResponseAsync(Response.MakeTraceResponse(request.Cache.Data));elseSendResponseAsync(Response.MakeErrorResponse("Unsupported HTTP method: "+request.Method));}protectedoverridevoidOnReceivedRequestError(HttpRequestrequest,stringerror){Console.WriteLine($"Request error:{error}");}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"HTTP session caught an error:{error}");}}classHttpCacheServer:NetCoreServer.HttpServer{publicHttpCacheServer(IPAddressaddress,intport):base(address,port){}protectedoverrideTcpSessionCreateSession(){returnnewHttpCacheSession(this);}protectedoverridevoidOnError(SocketErrorerror){Console.WriteLine($"HTTP session caught an error:{error}");}}classProgram{staticvoidMain(string[]args){// HTTP server portintport=8080;if(args.Length>0)port=int.Parse(args[0]);// HTTP server content pathstringwww="../../../../../www/api";if(args.Length>1)www=args[1];Console.WriteLine($"HTTP server port:{port}");Console.WriteLine($"HTTP server static content path:{www}");Console.WriteLine($"HTTP server website: http://localhost:{port}/api/index.html");Console.WriteLine();// Create a new HTTP servervarserver=newHttpCacheServer(IPAddress.Any,port);server.AddStaticContent(www,"/api");// Start the serverConsole.Write("Server starting...");server.Start();Console.WriteLine("Done!");Console.WriteLine("Press Enter to stop the server or '!' to restart the server...");// Perform text inputfor(;;){stringline=Console.ReadLine();if(string.IsNullOrEmpty(line))break;// Restart the serverif(line=="!"){Console.Write("Server restarting...");server.Restart();Console.WriteLine("Done!");}}// Stop the serverConsole.Write("Server stopping...");server.Stop();Console.WriteLine("Done!");}}}