HttpServer.cs

using System;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using Gepard.Configuration.Server;
using Gepard.Core;
using Gepard.Core.Main;

namespace Gepard
{
    public class HttpServer
    {
        public static string HttpServerName { get; set; }

        private TcpListener Server { get; }
        private Task Task { get; }
        private ServerConfig ServerConfig { get; }
        private ControllerHandler ControllerHandler { get; }
        
        public HttpServer(ServerConfig serverConfig, ControllerHandler controllerHandler)
        {
            HttpServerName = serverConfig.ServerName;
            ServerConfig = serverConfig;
            ControllerHandler = controllerHandler;

            Server = new TcpListener(IPAddress.Parse(ServerConfig.Ip), ServerConfig.Port);
            Task = new Task(AcceptBackground);
        }

        public void Start()
        {
            Server.Start();
            Task.Start();
            Console.WriteLine("Server started at " + Server.LocalEndpoint);
        }

        public void Stop()
        {
            Task.Dispose();
        }
        
        private void AcceptBackground()
        {
            while (true)
            {
                var client = Server.AcceptTcpClient();
                Task.Factory.StartNew(() => HandleClient(client));
            }
            // ReSharper disable once FunctionNeverReturns
        }
       
        private void HandleClient(TcpClient client)
        {
            var stream = client.GetStream();
            client.ReceiveTimeout = ServerConfig.KeepAliveTimeout * 1000;

            while (true)
            {
                try
                {
                    var strRequest = Receive(stream);
                    var response = ControllerHandler.Execute(strRequest, client.Client.LocalEndPoint.ToString());
                    Send(stream, response.ArrayBytes);
                    
                    if (response.ConnectionAlive) continue;
                    
                    client.Close();
                    break;
                }
                catch
                {
                    client.Close();
                    break;
                }
            }
        }
        
        private string Receive(NetworkStream stream)
        {
            var buffer = new byte[256];
            var data = "";

            while (stream.DataAvailable || data.Length == 0)
            {
                var bytesRead = stream.Read(buffer, 0, buffer.Length);
                data += Encoding.UTF8.GetString(buffer, 0, bytesRead);
            }

            return data;
        }

        private void Send(NetworkStream stream, byte[] msg)
        {
            stream.Write(msg, 0, msg.Length);
        }
    }
}