Entrada
Tot va començar quan un company em va suggerir que fes un petit servei web. Se suposava que havia de ser una cosa semblant a un tinder, però per a una trobada de TI. La funcionalitat és del tot senzilla, us registreu, ompliu un perfil i passeu al punt principal, és a dir, trobar un interlocutor i ampliar les vostres connexions i fer nous coneguts.
Aquí he de divagar i explicar una mica de mi, perquè en el futur quedi més clar per què vaig fer aquests passos en el desenvolupament.
En aquest moment ocupo la posició d'Artista Tècnic en un estudi de jocs, la meva experiència de programació en C# es basava només en escriure scripts i utilitats per a Unity i, a més, crear complements per treballar de baix nivell amb dispositius Android. Fora d'aquest món, encara no he triat i després he trobat aquesta oportunitat.
Part 1. Prototipatge de marcs
Després d'haver decidit com serà aquest servei, vaig començar a buscar opcions d'implementació. La manera més senzilla seria trobar algun tipus de solució ja feta, en la qual, com un mussol en un globus terraqüi, pugueu estirar els nostres mecànics i posar-ho tot per a la censura pública.
Però això no és interessant, no hi veia cap repte ni sentit, i per tant vaig començar a estudiar les tecnologies web i els mètodes d'interacció amb elles.
L'estudi va començar visualitzant articles i documentació a C # .Net. Aquí he trobat diverses maneres d'aconseguir la tasca. Hi ha molts mecanismes per interaccionar amb la xarxa, des de solucions completes com els serveis ASP.Net o Azure, fins a la interacció directa amb connexions TcpHttp.
Després d'haver fet el primer intent amb ASP, el vaig cancel·lar immediatament, al meu entendre que era una decisió massa difícil per al nostre servei. No utilitzarem ni un terç de les capacitats d'aquesta plataforma, així que vaig continuar la meva recerca. L'elecció va sorgir entre TCP i Http client-servidor. Aquí, a Habré, em vaig trobar amb un article sobre , després d'haver recollit i provat que, vaig decidir centrar-me a interaccionar amb connexions TCP, per alguna raó vaig pensar que http no em permetria crear una solució multiplataforma.
La primera versió del servidor incloïa la gestió de connexions, la publicació de contingut estàtic de la pàgina web i la inclusió d'una base de dades d'usuaris. I per començar, vaig decidir crear una funcionalitat per treballar amb el lloc, de manera que més endavant pogués vincular el processament de l'aplicació a Android i ios aquí.
Aquí teniu un codi
El fil principal que accepta clients en un bucle sense fi:
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);
}
}
}El mateix gestor del client:
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();
}
}
}
I la primera base de dades construïda amb SQL local: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}");
}
}
}
}
}
Com podeu veure, aquesta versió difereix poc de la de l'article. De fet, aquí només es va afegir la càrrega de pàgines des d'una carpeta de l'ordinador i la base de dades (que, per cert, no funcionava en aquesta versió, per l'arquitectura de connexió incorrecta).Capítol 2
Després de provar el servidor, vaig arribar a la conclusió que seria una gran solució (spoiler: no), pel nostre servei, així que el projecte va començar a adquirir lògica.
Pas a pas, van començar a aparèixer nous mòduls i la funcionalitat del servidor va créixer. El servidor té un domini de prova i un xifratge de connexió ssl.Una mica més de codi que descriu la lògica del servidor i el processament dels clients
Una versió actualitzada del servidor, inclòs l'ús d'un certificat.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(); } } }Així com un nou gestor de clients amb autorització mitjançant 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);
}
}
}
Però com que el servidor treballa exclusivament en una connexió TCP, és necessari crear un mòdul que reconegui el context de la sol·licitud. Vaig decidir que aquí és adequat un analitzador que dividirà la sol·licitud del client en parts separades amb les quals puc interactuar per donar al client les respostes necessàries.Analitzador
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;
}
}
}
La seva essència rau en el fet que amb l'ajuda d'expressions regulars per dividir la sol·licitud en parts. Rebem un missatge del client, seleccionem la primera línia, que conté el mètode i l'url de sol·licitud. A continuació, llegim les capçaleres, que introduïm en una matriu de la forma HeaderName = Content, i també trobem, si n'hi ha, el contingut que l'acompanya (per exemple, querystring) que també introduïm en una matriu similar. A més, l'analitzador esbrina si el client actual està autoritzat i guarda les seves dades. Totes les sol·licituds de clients autoritzats contenen un hash d'autorització, que s'emmagatzema en galetes, gràcies al qual és possible separar la lògica de treball addicional per a dos tipus de clients i donar-los les respostes correctes.Bé, una característica petita i agradable que s'hauria de traslladar a un mòdul independent, convertint sol·licituds com "site.com/@UserName" en pàgines d'usuari generades dinàmicament. Després de processar la sol·licitud, entren en joc els mòduls següents.
Capítol 3. Instal·lació del manillar, lubricació de la cadena
Tan bon punt s'ha completat l'analitzador, entra en joc el controlador, donant instruccions addicionals al servidor i dividint el control en dues parts.
manipulador senzill
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); }; } } }De fet, només hi ha una comprovació d'autorització de l'usuari, després de la qual s'inicia el processament de la sol·licitud.
Controladors de clients
Si l'usuari no està autoritzat, per a ell la funcionalitat només es basa en la visualització dels perfils d'usuari i la finestra de registre d'autorització. El codi d'un usuari autoritzat sembla aproximadament el mateix, així que no veig cap motiu per duplicar-lo.Usuari no autoritzat
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;}
}
}
}
I per descomptat, l'usuari ha de rebre algun contingut de les pàgines, de manera que per a les respostes hi ha el següent mòdul, que s'encarrega de donar resposta a una sol·licitud de recursos.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":
returnquot;{Header} text/html";
case ".css":
returnquot;{Header} text/css";
case ".js":
returnquot;{Header} text/javascript";
case ".jpg":
case ".jpeg":
case ".png":
case ".gif":
returnquot;{Header} image/{extension}";
default:
if (extension.Length > 1)
{
returnquot;{Header} application/" + extension.Substring(1);
}
else
{
returnquot;{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();
}
}
}
Però per mostrar a l'usuari el seu perfil i els perfils d'altres usuaris, vaig decidir utilitzar RazorEngine, o més aviat una part d'ell. També inclou la gestió de sol·licituds incorrectes i l'emissió del codi d'error adequat.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(); } } } }I per descomptat, perquè la verificació dels usuaris autoritzats funcioni, cal autorització. El mòdul d'autorització interactua amb la base de dades. Les dades rebudes dels formularis del lloc s'analitzen a partir del context, l'usuari es guarda i rep cookies i accés al servei a canvi.
Mòdul d'autorització
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);
}
}
}
}
I així és com es veu la base de dades:Base de dades
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;
}
}
}
}
I tot funciona com un rellotge, treballs d'autorització i registre, la funcionalitat mínima d'accés al servei ja està disponible i és el moment d'escriure una aplicació i lligar-ho tot amb les funcions principals per a les quals es fa tot.Capítol 4
Per reduir els costos laborals d'escriure dues aplicacions per a dues plataformes, vaig decidir fer una multiplataforma a Xamarin.Forms. De nou, gràcies al fet que està en C#. Després d'haver fet una aplicació de prova que simplement envia dades al servidor, em vaig trobar amb un moment interessant. Per a una sol·licitud del dispositiu, per diversió, la vaig implementar a HttpClient i la vaig llançar al servidor HttpRequestMessage que conté dades del formulari d'autorització en format json. Sense esperar res en particular, vaig obrir el registre del servidor i vaig veure una sol·licitud del dispositiu amb totes les dades allà. Estupor lleuger, consciència de tot el que s'ha fet durant les últimes 3 setmanes de tarda lànguida. Per comprovar la correcció de les dades enviades, vaig muntar un servidor de prova a HttpListner. Després d'haver rebut la següent sol·licitud, la vaig desmuntar en un parell de línies de codi i vaig obtenir les dades de KeyValuePair del formulari. L'anàlisi de consultes s'ha reduït a dues línies.
Vaig començar a provar més, no s'havia esmentat abans, però al servidor anterior encara vaig implementar un xat basat en websockets. Va funcionar bastant bé, però el principi d'interacció mitjançant Tcp era depriment, s'havia de produir massa addicional per tal de construir correctament la interacció de dos usuaris amb el registre de correspondència. Això inclou analitzar una sol·licitud de canvi de connexió i recopilar una resposta mitjançant el protocol RFC 6455. Per tant, al servidor de proves, vaig decidir crear una connexió websocket senzilla. Només per interessos.
Connexió de xat
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(); } } } } }I va funcionar. El propi servidor va configurar la connexió i va generar una clau de resposta. Ni tan sols vaig haver de configurar per separat el registre del servidor mitjançant ssl, n'hi ha prou que el sistema ja tingui un certificat instal·lat al port requerit.
Al costat del dispositiu i al costat del lloc, dos clients van intercanviar missatges, tot això es va registrar. No hi ha grans analitzadors que alentiren el servidor, res d'això era necessari. El temps de resposta s'ha reduït de 200 ms a 40-30 ms. I vaig prendre l'única decisió correcta.
Llenceu la implementació actual del servidor a Tcp i torneu a escriure-ho tot a Http. Ara el projecte es troba en l'etapa de redisseny, però segons principis d'interacció completament diferents. El funcionament dels dispositius i del lloc està sincronitzat i depurat i té un concepte comú, amb l'única diferència que els dispositius no necessiten generar pàgines html.
Sortida
"Sense saber el gual, no fiquis el cap a l'aigua" Crec que, abans de començar a treballar, hauria d'haver definit més clarament els objectius i els objectius, així com aprofundir en l'estudi de les tecnologies i mètodes necessaris per a la seva implantació en diversos clients. El projecte ja està a punt d'acabar-se, però potser tornaré per parlar de com vaig fer malbé determinades coses. Vaig aprendre molt durant el procés de desenvolupament, però hi ha més coses per aprendre en el futur. Si heu llegit fins aquí, gràcies per llegir-lo.
Font: www.habr.com
