Ċikliżmu avvanzat jew applikazzjoni klijent-server ibbażata fuq qafas C# .Net

Dħul

Kollox beda meta kollega ssuġġerixxa li nagħmel servizz web żgħir. Suppost kellha tkun xi ħaġa bħal tinder, iżda għal hangout tal-IT. Il-funzjonalità hija sempliċi għal kollox, tirreġistra, timla profil u timxi fuq il-punt ewlieni, jiġifieri, issib interlokutur u tespandi l-konnessjonijiet tiegħek u tagħmel konoxxenti ġodda.

Hawnhekk ikolli niddigress u ngħid ftit dwari nnifsi, biex fil-futur ikun aktar ċar għaliex ħadt passi bħal dawn fl-iżvilupp.

Fil-mument inżomm il-pożizzjoni ta 'Artist Tekniku fi studio tal-logħob, l-esperjenza tiegħi ta' programmar C# kienet ibbażata biss fuq il-kitba ta 'skripts u utilitajiet għal Unity u, minbarra dan, il-ħolqien ta' plugins għal xogħol ta 'livell baxx b'apparat android. Barra minn din id-dinja ċkejkna, għadni ma għażiltx u mbagħad sibt opportunità bħal din.

Parti 1. Frame Prototyping

Wara li ddeċidejt kif se jkun dan is-servizz, bdejt infittex għażliet għall-implimentazzjoni. L-eħfef mod ikun li ssib xi tip ta 'soluzzjoni lesta, li fuqha, bħal kokka fuq globu, tista' tiġbed il-mekkanika tagħna u tpoġġi l-ħaġa sħiħa għal ċensura pubblika.
Iżda dan mhux interessanti, ma rajt l-ebda sfida u sens f'dan, u għalhekk bdejt nistudja t-teknoloġiji tal-web u l-metodi ta 'interazzjoni magħhom.

L-istudju beda billi jara artikli u dokumentazzjoni fuq C # .Net. Hawnhekk sibt diversi modi biex inwettaq il-kompitu. Hemm ħafna mekkaniżmi għall-interazzjoni man-netwerk, minn soluzzjonijiet sħaħ bħal ASP.Net jew servizzi Azure, għal interazzjoni diretta mal-konnessjonijiet TcpHttp.

Wara li għamilt l-ewwel tentattiv ma 'ASP, ikkanċellajtha immedjatament, fl-opinjoni tiegħi kienet deċiżjoni diffiċli wisq għas-servizz tagħna. Mhux se nużaw lanqas terz tal-kapaċitajiet ta’ din il-pjattaforma, għalhekk komplejt it-tfittxija tiegħi. L-għażla qamet bejn TCP u Http client-server. Hawnhekk, fuq Habré, iltqajt ma’ artiklu dwar server multithreaded, wara li ġabar u ttestjat liema, iddeċidejt li niffoka fuq l-interazzjoni ma 'konnessjonijiet TCP, għal xi raġuni ħsibt li http ma jippermettilix noħloq soluzzjoni ta' pjattaformi differenti.

L-ewwel verżjoni tas-server kienet tinkludi l-immaniġġjar tal-konnessjonijiet, li jservu kontenut statiku tal-paġna tal-web, u inkluż database tal-utent. U biex nibda, iddeċidejt li nibni funzjonali biex taħdem mas-sit, sabiex aktar tard inkun nista 'torbot l-ipproċessar tal-applikazzjoni fuq android u ios hawn.

Hawn xi kodiċi
Il-ħajt ewlieni li jaċċetta klijenti f'linja bla tarf:

using System;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace ClearServer
{

    class Server
    {
        TcpListener Listener;
        public Server(int Port)
        {
            Listener = new TcpListener(IPAddress.Any, Port);
            Listener.Start();

            while (true)
            {
                TcpClient Client = Listener.AcceptTcpClient();
                Thread Thread = new Thread(new ParameterizedThreadStart(ClientThread));
                Thread.Start(Client);
            }
        }

        static void ClientThread(Object StateInfo)
        {
            new Client((TcpClient)StateInfo);
        }

        ~Server()
        {
            if (Listener != null)
            {
                Listener.Stop();
            }
        }

        static void Main(string[] args)
        {
            DatabaseWorker sqlBase = DatabaseWorker.GetInstance;

            new Server(80);
        }
    }
}

Il-customer handler innifsu:

using System;
using System.IO;
using System.Net.Sockets;
using System.Text;
using System.Text.RegularExpressions;

namespace ClearServer
{
    class Client
    {


        public Client(TcpClient Client)
        {

            string Message = "";
            byte[] Buffer = new byte[1024];
            int Count;
            while ((Count = Client.GetStream().Read(Buffer, 0, Buffer.Length)) > 0)
            {
                Message += Encoding.UTF8.GetString(Buffer, 0, Count);

                if (Message.IndexOf("rnrn") >= 0 || Message.Length > 4096)
                {
                    Console.WriteLine(Message);
                    break;
                }
            }

            Match ReqMatch = Regex.Match(Message, @"^w+s+([^s?]+)[^s]*s+HTTP/.*|");
            if (ReqMatch == Match.Empty)
            {
                ErrorWorker.SendError(Client, 400);
                return;
            }
            string RequestUri = ReqMatch.Groups[1].Value;
            RequestUri = Uri.UnescapeDataString(RequestUri);
            if (RequestUri.IndexOf("..") >= 0)
            {
                ErrorWorker.SendError(Client, 400);
                return;
            }
            if (RequestUri.EndsWith("/"))
            {
                RequestUri += "index.html";
            }

            string FilePath =

quot;D:/Web/TestSite{RequestUri}";
            if (!File.Exists(FilePath))

{

ErrorWorker.SendError(Client, 404);

return;

}
            string Extension = RequestUri.Substring(RequestUri.LastIndexOf('.'));
            string ContentType = "";
            switch (Extension)

{

case ".htm":

case ".html":

ContentType = "text/html";

break;

case ".css":

ContentType = "text/css";

break;

case ".js":

ContentType = "text/javascript";

break;

case ".jpg":

ContentType = "image/jpeg";

break;

case ".jpeg":

case ".png":

case ".gif":

ContentType =

quot;image/{Extension.Substring(1)}";

break;

default:

if (Extension.Length > 1)

{

ContentType =

quot;application/{Extension.Substring(1)}";

}

else

{

ContentType = "application/unknown";

}

break;

}
            FileStream FS;

try

{

FS = new FileStream(FilePath, FileMode.Open, FileAccess.Read, FileShare.Read);

}

catch (Exception)

{

ErrorWorker.SendError(Client, 500);

return;

}
            string Headers =

quot;HTTP/1.1 200 OKnContent-Type: {ContentType}nContent-Length: {FS.Length}nn";

byte[] HeadersBuffer = Encoding.ASCII.GetBytes(Headers);

Client.GetStream().Write(HeadersBuffer, 0, HeadersBuffer.Length);
            while (FS.Position < FS.Length)

{

Count = FS.Read(Buffer, 0, Buffer.Length);

Client.GetStream().Write(Buffer, 0, Count);

}
            FS.Close();

Client.Close();

}

}

}

U l-ewwel database mibnija fuq SQL lokali:
using System;
using System.Data.Linq;
namespace ClearServer
{
    class DatabaseWorker
    {

        private static DatabaseWorker instance;

        public static DatabaseWorker GetInstance
        {
            get
            {
                if (instance == null)
                    instance = new DatabaseWorker();
                return instance;
            }
        }


        private DatabaseWorker()
        {
            string connectionStr = databasePath;
            using (DataContext db = new DataContext(connectionStr))
            {
                Table<User> users = db.GetTable<User>();
                foreach (var item in users)
                {
                    Console.WriteLine(

quot;{item.login} {item.password}");

}

}

}

}

}

Kif tistgħu taraw, din il-verżjoni ftit differenti minn dik fl-artiklu. Fil-fatt, hawn biss ġew miżjuda t-tagħbija ta 'paġni minn folder fuq il-kompjuter u d-database (li, mill-mod, ma ħadmux f'din il-verżjoni, minħabba l-arkitettura ta' konnessjoni mhux korretta).
Kapitolu 2
Wara li ttestja s-server, wasalt għall-konklużjoni li din tkun soluzzjoni kbira (spoiler: le), għas-servizz tagħna, għalhekk il-proġett beda jakkwista loġika.

Pass pass, bdew jidhru moduli ġodda u l-funzjonalità tas-server kibret. Is-server għandu dominju tat-test u encryption tal-konnessjoni ssl.
Ftit aktar kodiċi li jiddeskrivi l-loġika tas-server u l-ipproċessar tal-klijenti

Verżjoni aġġornata tas-server, inkluż l-użu ta' ċertifikat.
using System;
using System.Net;
using System.Net.Sockets;
using System.Reflection;
using System.Security;
using System.Security.Cryptography.X509Certificates;
using System.Security.Permissions;
using System.Security.Policy;
using System.Threading;


namespace ClearServer
{

    sealed class Server
    {
        readonly bool ServerRunning = true;
        readonly TcpListener sslListner;
        public static X509Certificate serverCertificate = null;
        Server()
        {
            serverCertificate = X509Certificate.CreateFromSignedFile(@"C:sslitinder.online.crt");
            sslListner = new TcpListener(IPAddress.Any, 443);
            sslListner.Start();
            Console.WriteLine("Starting server.." + serverCertificate.Subject + "n" + Assembly.GetExecutingAssembly().Location);
            while (ServerRunning)
            {
                TcpClient SslClient = sslListner.AcceptTcpClient();
                Thread SslThread = new Thread(new ParameterizedThreadStart(ClientThread));
                SslThread.Start(SslClient);
            }
            
        }
        static void ClientThread(Object StateInfo)
        {
            new Client((TcpClient)StateInfo);
        }

        ~Server()
        {
            if (sslListner != null)
            {
                sslListner.Stop();
            }
        }

        public static void Main(string[] args)
        {
            if (AppDomain.CurrentDomain.IsDefaultAppDomain())
            {
                Console.WriteLine("Switching another domain");
                new AppDomainSetup
                {
                    ApplicationBase = AppDomain.CurrentDomain.SetupInformation.ApplicationBase
                };
                var current = AppDomain.CurrentDomain;
                var strongNames = new StrongName[0];
                var domain = AppDomain.CreateDomain(
                    "ClearServer", null,
                    current.SetupInformation, new PermissionSet(PermissionState.Unrestricted),
                    strongNames);
                domain.ExecuteAssembly(Assembly.GetExecutingAssembly().Location);
            }
            new Server();
        }
    }
}
Kif ukoll customer handler ġdid b'awtorizzazzjoni permezz ta' ssl:
using ClearServer.Core.Requester;
using System;
using System.Net.Security;
using System.Net.Sockets;

namespace ClearServer
{
    public class Client
    {
        public Client(TcpClient Client)
        {
            SslStream SSlClientStream = new SslStream(Client.GetStream(), false);
            try
            {
                SSlClientStream.AuthenticateAsServer(Server.serverCertificate, clientCertificateRequired: false, checkCertificateRevocation: true);
            }
            catch (Exception e)
            {
                Console.WriteLine(
                    "---------------------------------------------------------------------n" +


quot;|{DateTime.Now:g}n|------------n|{Client.Client.RemoteEndPoint}n|------------n|Exception: {e.Message}n|------------n|Authentication failed - closing the connection.n" +

"---------------------------------------------------------------------n");

SSlClientStream.Close();

Client.Close();

}

new RequestContext(SSlClientStream, Client);

}
    }

}



Iżda peress li s-server jaħdem esklussivament fuq konnessjoni TCP, huwa meħtieġ li jinħoloq modulu li jista 'jirrikonoxxi l-kuntest tat-talba. Iddeċidejt li parser huwa adattat hawnhekk li jkisser it-talba mill-klijent f'partijiet separati li magħhom nista' ninteraġixxi sabiex nagħti lill-klijent it-tweġibiet meħtieġa.
parser
using ClearServer.Core.UserController;
using ReServer.Core.Classes;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Security;
using System.Net.Sockets;
using System.Text;
using System.Text.RegularExpressions;

namespace ClearServer.Core.Requester
{
    public class RequestContext
    {
        public string Message = "";
        private readonly byte[] buffer = new byte[1024];
        public string RequestMethod;
        public string RequestUrl;
        public User RequestProfile;
        public User CurrentUser = null;
        public List<RequestValues> HeadersValues;
        public List<RequestValues> FormValues;
        private TcpClient TcpClient;

        private event Action<SslStream, RequestContext> OnRead = RequestHandler.OnHandle;

        DatabaseWorker databaseWorker = new DatabaseWorker();

        public RequestContext(SslStream ClientStream, TcpClient Client)
        {

            this.TcpClient = Client;
            try
            {
                ClientStream.BeginRead(buffer, 0, buffer.Length, ClientRead, ClientStream);
            }
            catch { return; }
        }
        private void ClientRead(IAsyncResult ar)
        {
            SslStream ClientStream = (SslStream)ar.AsyncState;

            if (ar.IsCompleted)
            {
                Message = Encoding.UTF8.GetString(buffer);
                Message = Uri.UnescapeDataString(Message);
                Console.WriteLine(

quot;n{DateTime.Now:g} Client IP:{TcpClient.Client.RemoteEndPoint}n{Message}");

RequestParse();

HeadersValues = HeaderValues();

FormValues = ContentValues();

UserParse();

ProfileParse();

OnRead?.Invoke(ClientStream, this);

}

}
        private void RequestParse()

{

Match methodParse = Regex.Match(Message, @"(^w+)s+([^s?]+)[^s]*s+HTTP/.*|");

RequestMethod = methodParse.Groups[1].Value.Trim();

RequestUrl = methodParse.Groups[2].Value.Trim();

}

private void UserParse()

{

string cookie;

try

{

if (HeadersValues.Any(x => x.Name.Contains("Cookie")))

{

cookie = HeadersValues.FirstOrDefault(x => x.Name.Contains("Cookie")).Value;

try

{

CurrentUser = databaseWorker.CookieValidate(cookie);

}

catch { }

}

}

catch { }
        }

private List<RequestValues> HeaderValues()

{

var values = new List<RequestValues>();

var parse = Regex.Matches(Message, @"(.*?): (.*?)n");

foreach (Match match in parse)

{

values.Add(new RequestValues()

{

Name = match.Groups[1].Value.Trim(),

Value = match.Groups[2].Value.Trim()

});

}

return values;

}
        private void ProfileParse()

{

if (RequestUrl.Contains("@"))

{

RequestProfile = databaseWorker.FindUser(RequestUrl.Substring(2));

RequestUrl = "/profile";

}

}

private List<RequestValues> ContentValues()

{

var values = new List<RequestValues>();

var output = Message.Trim('n').Split().Last();

var parse = Regex.Matches(output, @"([^&].*?)=([^&]*b)");

foreach (Match match in parse)

{

values.Add(new RequestValues()

{

Name = match.Groups[1].Value.Trim(),

Value = match.Groups[2].Value.Trim().Replace('+', ' ')

});

}

return values;

}

}

}

L-essenza tagħha tinsab fil-fatt li bl-għajnuna ta 'espressjonijiet regolari tkisser it-talba f'partijiet. Nirċievu messaġġ mill-klijent, agħżel l-ewwel linja, li fiha l-metodu u t-talba url. Imbagħad naqraw l-intestaturi, li nsuqu f'firxa tal-forma HeaderName = Kontenut, u nsibu wkoll, jekk ikun hemm, il-kontenut ta 'akkumpanjament (per eżempju, querystring) li nsuqu wkoll f'firxa simili. Barra minn hekk, il-parser isir jaf jekk il-klijent attwali huwiex awtorizzat u jiffranka d-dejta tiegħu. It-talbiet kollha minn klijenti awtorizzati fihom hash ta 'awtorizzazzjoni, li huwa maħżun fil-cookies, li grazzi għalih huwa possibbli li tissepara aktar loġika ta' xogħol għal żewġ tipi ta 'klijenti u tagħtihom it-tweġibiet korretti.
Ukoll, karatteristika żgħira u sabiħa li għandha titmexxa f'modulu separat, li tikkonverti talbiet bħal "site.com/@UserName" f'paġni tal-utent ġenerati b'mod dinamiku. Wara l-ipproċessar tat-talba, jidħlu fis-seħħ il-moduli li ġejjin.
Kapitolu 3. Installazzjoni tal-manubri, lubrikazzjoni tal-katina
Hekk kif il-parser ikun lesta, il-handler jidħol fis-seħħ, jagħti aktar struzzjonijiet lis-server u jaqsam il-kontroll f'żewġ partijiet.
handler sempliċi
using ClearServer.Core.UserController;
using System.Net.Security;
namespace ClearServer.Core.Requester
{
    public class RequestHandler
    {
        public static void OnHandle(SslStream ClientStream, RequestContext context)
        {

            if (context.CurrentUser != null)
            {
                new AuthUserController(ClientStream, context);
            }
            else 
            {
                new NonAuthUserController(ClientStream, context);
            };
        }
    }
}
Fil-fatt, hemm kontroll wieħed biss għall-awtorizzazzjoni tal-utent, u wara jibda l-ipproċessar tat-talba.
Kontrolluri tal-Klijent

Jekk l-utent ma jkunx awtorizzat, allura għalih il-funzjonalità hija bbażata biss fuq il-wiri tal-profili tal-utent u t-tieqa tar-reġistrazzjoni tal-awtorizzazzjoni. Il-kodiċi għal utent awtorizzat jidher madwar l-istess, għalhekk ma nara l-ebda raġuni biex nidduplikah.
Utent mhux awtorizzat
using ClearServer.Core.Requester;
using System.IO;
using System.Net.Security;

namespace ClearServer.Core.UserController
{
    internal class NonAuthUserController
    {
        private readonly SslStream ClientStream;
        private readonly RequestContext Context;
        private readonly WriteController WriteController;
        private readonly AuthorizationController AuthorizationController;

        private readonly string ViewPath = "C:/Users/drdre/source/repos/ClearServer/View";

        public NonAuthUserController(SslStream clientStream, RequestContext context)
        {
            this.ClientStream = clientStream;
            this.Context = context;
            this.WriteController = new WriteController(clientStream);
            this.AuthorizationController = new AuthorizationController(clientStream, context);
            ResourceLoad();
        }

        void ResourceLoad()
        {
            string[] blockextension = new string[] {"cshtml", "html", "htm"};
            bool block = false;
            foreach (var item in blockextension)
            {
                if (Context.RequestUrl.Contains(item))
                {
                    block = true;
                    break;
                }
            }
            string FilePath = "";
            string Header = "";
            var RazorController = new RazorController(Context, ClientStream);
            
            switch (Context.RequestMethod)
            {
                case "GET":
                    switch (Context.RequestUrl)
                    {
                        case "/":
                            FilePath = ViewPath + "/loginForm.html";
                            Header =

quot;HTTP/1.1 200 OKnContent-Type: text/html";

WriteController.DefaultWriter(Header, FilePath);

break;

case "/profile":

RazorController.ProfileLoader(ViewPath);

break;

default:

//в данном блоке кода происходит отсечение запросов к серверу по прямому адресу страницы вида site.com/page.html

if (!File.Exists(ViewPath + Context.RequestUrl) | block)

{

RazorController.ErrorLoader(404);
                            }

else if (Path.HasExtension(Context.RequestUrl) && File.Exists(ViewPath + Context.RequestUrl))

{

Header = WriteController.ContentType(Context.RequestUrl);

FilePath = ViewPath + Context.RequestUrl;

WriteController.DefaultWriter(Header, FilePath);

}

break;

}

break;
                case "POST":

AuthorizationController.MethodRecognizer();

break;
            }
        }
    }

}



U ovvjament, l-utent irid jirċievi xi kontenut tal-paġni, għalhekk għat-tweġibiet hemm il-modulu li ġej, li huwa responsabbli biex iwieġeb għal talba għal riżorsi.
WriterController
using System;
using System.IO;
using System.Net.Security;
using System.Text;

namespace ClearServer.Core.UserController
{
    public class WriteController
    {
        SslStream ClientStream;
        public WriteController(SslStream ClientStream)
        {
            this.ClientStream = ClientStream;
        }

        public void DefaultWriter(string Header, string FilePath)
        {
            FileStream fileStream;
            try
            {
                fileStream = new FileStream(FilePath, FileMode.Open, FileAccess.ReadWrite, FileShare.ReadWrite);
                Header =

quot;{Header}nContent-Length: {fileStream.Length}nn";

ClientStream.Write(Encoding.UTF8.GetBytes(Header));

byte[] response = new byte[fileStream.Length];

fileStream.BeginRead(response, 0, response.Length, OnFileRead, response);

}

catch { }

}
        public string ContentType(string Uri)

{

string extension = Path.GetExtension(Uri);

string Header = "HTTP/1.1 200 OKnContent-Type:";

switch (extension)

{

case ".html":

case ".htm":

return

quot;{Header} text/html";

case ".css":

return

quot;{Header} text/css";

case ".js":

return

quot;{Header} text/javascript";

case ".jpg":

case ".jpeg":

case ".png":

case ".gif":

return

quot;{Header} image/{extension}";

default:

if (extension.Length > 1)

{

return

quot;{Header} application/" + extension.Substring(1);

}

else

{

return

quot;{Header} application/unknown";

}

}

}
        public void OnFileRead(IAsyncResult ar)

{

if (ar.IsCompleted)

{

var file = (byte[])ar.AsyncState;

ClientStream.BeginWrite(file, 0, file.Length, OnClientSend, null);

}

}
        public void OnClientSend(IAsyncResult ar)

{

if (ar.IsCompleted)

{

ClientStream.Close();

}

}

}

Iżda sabiex nuri lill-utent il-profil tiegħu u l-profili ta 'utenti oħra, iddeċidejt li nuża RazorEngine, jew aħjar parti minnu. Jinkludi wkoll l-immaniġġjar ta’ talbiet ħżiena u l-ħruġ tal-kodiċi ta’ żball xieraq.
RazorController
using ClearServer.Core.Requester;
using RazorEngine;
using RazorEngine.Templating;
using System;
using System.IO;
using System.Net;
using System.Net.Security;

namespace ClearServer.Core.UserController
{
    internal class RazorController
    {
        private RequestContext Context;
        private SslStream ClientStream;
        dynamic PageContent;


        public RazorController(RequestContext context, SslStream clientStream)
        {
            this.Context = context;
            this.ClientStream = clientStream;

        }

        public void ProfileLoader(string ViewPath)
        {
            string Filepath = ViewPath + "/profile.cshtml";
            if (Context.RequestProfile != null)
            {
                if (Context.CurrentUser != null && Context.RequestProfile.login == Context.CurrentUser.login)
                {
                    try
                    {
                        PageContent = new { isAuth = true, Name = Context.CurrentUser.name, Login = Context.CurrentUser.login, Skills = Context.CurrentUser.skills };
                        ClientSend(Filepath, Context.CurrentUser.login);
                    }
                    catch (Exception e) { Console.WriteLine(e); }

                }
                else
                {
                    try
                    {
                        PageContent = new { isAuth = false, Name = Context.RequestProfile.name, Login = Context.RequestProfile.login, Skills = Context.RequestProfile.skills };
                        ClientSend(Filepath, "PublicProfile:"+ Context.RequestProfile.login);
                    }
                    catch (Exception e) { Console.WriteLine(e); }
                }
            }
            else
            {
                ErrorLoader(404);
            }


        }

        public void ErrorLoader(int Code)
        {
            try
            {
                PageContent = new { ErrorCode = Code, Message = ((HttpStatusCode)Code).ToString() };
                string ErrorPage = "C:/Users/drdre/source/repos/ClearServer/View/Errors/ErrorPage.cshtml";
                ClientSend(ErrorPage, Code.ToString());
            }
            catch { }

        }

        private void ClientSend(string FilePath, string Key)
        {
            var template = File.ReadAllText(FilePath);
            var result = Engine.Razor.RunCompile(template, Key, null, (object)PageContent);
            byte[] buffer = System.Text.Encoding.UTF8.GetBytes(result);
            ClientStream.BeginWrite(buffer, 0, buffer.Length, OnClientSend, ClientStream);
        }

        private void OnClientSend(IAsyncResult ar)
        {
            if (ar.IsCompleted)
            {
                ClientStream.Close();
            }
        }
    }
}

U ovvjament, sabiex il-verifika tal-utenti awtorizzati taħdem, hija meħtieġa awtorizzazzjoni. Il-modulu ta' awtorizzazzjoni jinteraġixxi mad-database. Id-dejta riċevuta mill-formoli fuq is-sit hija analizzata mill-kuntest, l-utent jiġi ffrankat u jirċievi cookies u aċċess għas-servizz bi tpattija.
Modulu ta' awtorizzazzjoni
using ClearServer.Core.Cookies;
using ClearServer.Core.Requester;
using ClearServer.Core.Security;
using System;
using System.Linq;
using System.Net.Security;
using System.Text;

namespace ClearServer.Core.UserController
{
    internal class AuthorizationController
    {
        private SslStream ClientStream;
        private RequestContext Context;
        private UserCookies cookies;
        private WriteController WriteController;
        DatabaseWorker DatabaseWorker;
        RazorController RazorController;
        PasswordHasher PasswordHasher;
        public AuthorizationController(SslStream clientStream, RequestContext context)
        {
            ClientStream = clientStream;
            Context = context;
            DatabaseWorker = new DatabaseWorker();
            WriteController = new WriteController(ClientStream);
            RazorController = new RazorController(context, clientStream);
            PasswordHasher = new PasswordHasher();
        }

        internal void MethodRecognizer()
        {
            if (Context.FormValues.Count == 2 && Context.FormValues.Any(x => x.Name == "password")) Authorize();
            else if (Context.FormValues.Count == 3 && Context.FormValues.Any(x => x.Name == "regPass")) Registration();
            else
            {
                RazorController.ErrorLoader(401);
            }
        }

        private void Authorize()
        {
            var values = Context.FormValues;
            var user = new User()
            {
                login = values[0].Value,
                password = PasswordHasher.PasswordHash(values[1].Value)
            };
            user = DatabaseWorker.UserAuth(user);
            if (user != null)
            {
                cookies = new UserCookies(user.login, user.password);
                user.cookie = cookies.AuthCookie;
                DatabaseWorker.UserUpdate(user);
                var response = Encoding.UTF8.GetBytes(

quot;HTTP/1.1 301 Moved PermanentlynLocation: /@{user.login}nSet-Cookie: {cookies.AuthCookie}; Expires={DateTime.Now.AddDays(2):R}; Secure; HttpOnlynn");

ClientStream.BeginWrite(response, 0, response.Length, WriteController.OnClientSend, null);
            }

else

{

RazorController.ErrorLoader(401);
            }

}
        private void Registration()

{

var values = Context.FormValues;

var user = new User()

{

name = values[0].Value,

login = values[1].Value,

password = PasswordHasher.PasswordHash(values[2].Value),

};

cookies = new UserCookies(user.login, user.password);

user.cookie = cookies.AuthCookie;

if (DatabaseWorker.LoginValidate(user.login))

{

Console.WriteLine("User ready");

Console.WriteLine(

quot;{user.password} {user.password.Trim().Length}");

DatabaseWorker.UserRegister(user);

var response = Encoding.UTF8.GetBytes(

quot;HTTP/1.1 301 Moved PermanentlynLocation: /@{user.login}nSet-Cookie: {user.cookie}; Expires={DateTime.Now.AddDays(2):R}; Secure; HttpOnlynn");

ClientStream.BeginWrite(response, 0, response.Length, WriteController.OnClientSend, null);

}

else

{

RazorController.ErrorLoader(401);

}

}

}

}



U hekk tidher id-database:
Database
using ClearServer.Core.UserController;
using System;
using System.Data.Linq;
using System.Linq;

namespace ClearServer
{
    class DatabaseWorker
    {

        private readonly Table<User> users = null;
        private readonly DataContext DataBase = null;
        private const string connectionStr = @"путькбазе";

        public DatabaseWorker()
        {
            DataBase = new DataContext(connectionStr);
            users = DataBase.GetTable<User>();
        }

        public User UserAuth(User User)
        {
            try
            {
                var user = users.SingleOrDefault(t => t.login.ToLower() == User.login.ToLower() && t.password == User.password);
                if (user != null)
                    return user;
                else
                    return null;
            }
            catch (Exception)
            {
                return null;
            }

        }

        public void UserRegister(User user)
        {
            try
            {
                users.InsertOnSubmit(user);
                DataBase.SubmitChanges();
                Console.WriteLine(

quot;User{user.name} with id {user.uid} added");

foreach (var item in users)

{

Console.WriteLine(item.login + "n");

}

}

catch (Exception e)

{

Console.WriteLine(e);

}
        }
        public bool LoginValidate(string login)

{

if (users.Any(x => x.login.ToLower() == login.ToLower()))

{

Console.WriteLine("Login already exists");

return false;

}

return true;

}

public void UserUpdate(User user)

{

var UserToUpdate = users.FirstOrDefault(x => x.uid == user.uid);

UserToUpdate = user;

DataBase.SubmitChanges();

Console.WriteLine(

quot;User {UserToUpdate.name} with id {UserToUpdate.uid} updated");

foreach (var item in users)

{

Console.WriteLine(item.login + "n");

}

}

public User CookieValidate(string CookieInput)

{

User user = null;

try

{

user = users.SingleOrDefault(x => x.cookie == CookieInput);

}

catch

{

return null;

}

if (user != null) return user;

else return null;

}

public User FindUser(string login)

{

User user = null;

try

{

user = users.Single(x => x.login.ToLower() == login.ToLower());

if (user != null)

{

return user;

}

else

{

return null;

}

}

catch (Exception)

{

return null;

}

}

}

}


U kollox jaħdem bħal xogħol tal-arloġġ, awtorizzazzjoni u reġistrazzjoni, il-funzjonalità minima tal-aċċess għas-servizz diġà hija disponibbli u wasal iż-żmien li tikteb applikazzjoni u torbot il-ħaġa sħiħa mal-funzjonijiet ewlenin li għalihom isir kollox.
Kapitolu 4
Biex tnaqqas l-ispejjeż tax-xogħol tal-kitba ta 'żewġ applikazzjonijiet għal żewġ pjattaformi, iddeċidejt li nagħmel cross-platform fuq Xamarin.Forms. Għal darb'oħra, grazzi għall-fatt li huwa f'C#. Wara li għamilt applikazzjoni tat-test li sempliċement tibgħat id-dejta lis-server, ilħaqt f'mument wieħed interessanti. Għal talba mill-apparat, għall-gost, implimentajtha fuq HttpClient u erfagħha fuq is-server HttpRequestMessage li fih data mill-formola ta 'awtorizzazzjoni fil-format json. Mingħajr ma nistenna xejn b'mod partikolari, ftaħt il-log tas-server u rajt talba mill-apparat bid-dejta kollha hemmhekk. Stupor ħafif, għarfien ta 'dak kollu li sar matul l-aħħar 3 ġimgħat ta' filgħaxija languid. Biex tivverifika l-korrettezza tad-dejta mibgħuta, immuntajt server tat-test fuq HttpListner. Wara li rċevejt it-talba li jmiss diġà fuqha, ħadtha barra fi ftit linji ta 'kodiċi, sibt id-dejta KeyValuePair mill-formola. Parsing tal-mistoqsijiet imnaqqas għal żewġ linji.
Bdejt nittestja aktar, ma ssemmietx qabel, iżda fuq is-server preċedenti xorta implimentajt chat mibni fuq websockets. Ħadem pjuttost tajjeb, iżda l-prinċipju stess ta 'interazzjoni permezz ta' Tcp kien deprimenti, kellu jiġi prodott wisq żejda sabiex tinbena b'mod korrett l-interazzjoni ta 'żewġ utenti mal-illoggjar tal-korrispondenza. Dan jinkludi parsing ta 'talba għal bidla ta' konnessjoni u ġbir ta 'rispons bl-użu tal-protokoll RFC 6455. Għalhekk, fis-server tat-test, iddeċidejt li noħloq konnessjoni sempliċi tal-websocket. Purament għall-fini ta 'interess.
Konnessjoni taċ-chat
 private static async void HandleWebsocket(HttpListenerContext context)
        {
            var socketContext = await context.AcceptWebSocketAsync(null);
            var socket = socketContext.WebSocket;
            Locker.EnterWriteLock();
            try
            {
                Clients.Add(socket);
            }
            finally
            {
                Locker.ExitWriteLock();
            }

            while (true)
            {
                var buffer = new ArraySegment<byte>(new byte[1024]);
                var result = await socket.ReceiveAsync(buffer, CancellationToken.None);
                var str = Encoding.Default.GetString(buffer);
                Console.WriteLine(str);

                for (int i = 0; i < Clients.Count; i++)
                {
                    WebSocket client = Clients[i];

                    try
                    {
                        if (client.State == WebSocketState.Open)
                        {
                            
                            await client.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);
                        }
                    }
                    catch (ObjectDisposedException)
                    {
                        Locker.EnterWriteLock();
                        try
                        {
                            Clients.Remove(client);
                            i--;
                        }
                        finally
                        {
                            Locker.ExitWriteLock();
                        }
                    }
                }
            }
        }

U ħadem. Is-server innifsu waqqaf il-konnessjoni, ġġenera ċavetta ta 'rispons. Lanqas kelli nikkonfigura separatament ir-reġistrazzjoni tas-server permezz ta 'ssl, huwa biżżejjed li s-sistema diġà għandha ċertifikat installat fuq il-port meħtieġ.
Fuq in-naħa tal-apparat u fuq in-naħa tas-sit, żewġ klijenti skambjaw messaġġi, dan kollu ġie illoggjat. L-ebda parsers enormi ma jonqos is-server, xejn minn dan ma kien meħtieġ. Il-ħin tar-rispons tnaqqas minn 200ms għal 40-30ms. U wasalt għall-unika deċiżjoni t-tajba.

Armi l-implimentazzjoni attwali tas-server fuq Tcp u erġa' ikteb kollox taħt Http. Issa l-proġett jinsab fl-istadju ta 'disinn mill-ġdid, iżda skond prinċipji ta' interazzjoni kompletament differenti. It-tħaddim tal-apparati u s-sit huwa sinkronizzat u debugged u għandu kunċett komuni, bl-unika differenza li l-apparati m'għandhomx għalfejn jiġġeneraw paġni html.
Output
"Li ma tafx il-ford, iddaħħalx rasek fl-ilma" Naħseb, qabel ma nibda x-xogħol, ikolli ddefinit b'mod aktar ċar l-għanijiet u l-għanijiet, kif ukoll nidħol fl-istudju tat-teknoloġiji u l-metodi meħtieġa għall-implimentazzjoni tagħhom fuq diversi klijenti. Il-proġett diġà wasal lejn it-tlestija, imma forsi nerġa’ nerġa’ nitkellem dwar kif erġajt ħejt ċerti affarijiet. Tgħallimt ħafna matul il-proċess ta 'żvilupp, iżda hemm aktar x'titgħallem fil-futur. Jekk qrajt s'issa, allura grazzi tal-qari.
Sors: www.habr.com