🥇C# .Net フレームワークに基づく高度な自転車構築またはクライアントサーバーアプリケーション

エントリー

すべては、同僚が小さな Web サービスを作成することを提案したときに始まりました。 IT 関係者向けの Tinder のようなものになるはずでした。機能は非常にシンプルで、登録してプロフィールを記入し、話すべき人を見つけて人脈を広げ、新しい知り合いを作るという主要なポイントに進みます。

ここで私は一旦退いて、私自身について少し話さなければなりません。そうすれば、なぜ私が開発においてそのような措置を講じたのかが将来より明確になるでしょう。

現時点では、私はあるゲームスタジオでテクニカルアーティストの役職に就いていますが、C# でのプログラミング経験は、Unity 用のスクリプトとユーティリティの作成と、これに加えて Android デバイスでの低レベル作業用のプラグインの作成のみに基づいて構築されています。私はまだこの小さな世界を超えて冒険をしていませんでしたが、そのような機会が訪れました。

パート 1. フレームのプロトタイピング

このサービスがどのようなものであるかを決めたので、実装のオプションを探し始めました。最も簡単なのは、地球上のフクロウのように、私たちのメカニックが引っ張られ、すべてが公衆の非難にさらされる可能性がある、ある種の既製の解決策を見つけることです。
しかし、これは面白くなく、何の挑戦も意味も感じられなかったので、Web テクノロジーと Web テクノロジーと対話する方法を勉強し始めました。

私は C# .Net に関する記事やドキュメントを見て勉強を始めました。ここで、タスクを完了するためのさまざまな方法を見つけました。 ASP.Net や Azure サービスのような本格的なソリューションから、TcpHttp 接続との直接対話まで、ネットワークと対話するためのメカニズムは数多くあります。

初めて ASP を利用しようとしたとき、私はすぐに拒否しましたが、私の考えでは、これは当社のサービスにとっては難しすぎる決断でした。このプラットフォームの機能の XNUMX 分の XNUMX も使用しないだろうということで、検索を続けました。選択は、TCP と Http クライアントサーバーの間で行われました。ここで、ハブレについての記事を見つけました。マルチスレッドサーバーを収集してテストした後、何らかの理由で http ではクロスプラットフォームソリューションを作成できないと考えたため、TCP 接続との対話に特に焦点を当てることにしました。

サーバーの最初のバージョンには、接続処理、静的な Web ページコンテンツの提供、およびユーザーデータベースが含まれていました。そしてまず、後で Android と iOS 上でアプリケーションの処理を追加できるように、サイトと連携するための機能を構築することにしました。

ここにコードがあります
無限ループでクライアントを受信するメインスレッド:

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);
        }
    }
}

クライアントハンドラー自体:

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();

}

}

}

そして、ローカル SQL 上に構築された最初のデータベース:
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}");

}

}

}

}

}

ご覧のとおり、このバージョンは記事内のバージョンとほとんど変わりません。 実際、ここでは、コンピューター上のフォルダーとデータベースからのページの読み込みを追加しただけです (ちなみに、接続アーキテクチャが間違っていたため、このバージョンでは機能しませんでした)。
第 2 章 ホイールのネジ止め
サーバーをテストした後、これが優れたソリューションであるという結論に達しました(スポイラー: いいえ）、私たちのサービスのために、プロジェクトはロジックを獲得し始めました。

段階的に、新しいモジュールが登場し始め、サーバーの機能が拡張されました。 サーバーはテスト ドメインと SSL 接続暗号化を取得しました。
サーバーとクライアントの処理ロジックを説明するコードをもう少し追加します。

証明書の使用を含むサーバーの更新バージョン。
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();
        }
    }
}
また、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);

}
    }

}



ただし、サーバーは TCP 接続のみで実行されるため、リクエストのコンテキストを認識できるモジュールを作成する必要があります。 ここでは、クライアントからのリクエストを個別の部分に分割して、クライアントに必要な回答を与えるために対話できるパーサーが適していると判断しました。
パーサー
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;

}

}

}

その本質は、正規表現を使用してリクエストを複数の部分に分割することです。 クライアントからメッセージを受け取り、メソッドとリクエスト URL が含まれる最初の行を選択します。 次に、ヘッダーを読み取り、HeaderName=Content 形式の配列に入れます。また、利用可能な場合は、付随するコンテンツ (クエリ文字列など) も見つけて、これも同様の配列に入れます。 さらに、パーサーは現在のクライアントが認証されているかどうかを調べ、そのデータを保存します。 承認されたクライアントからのすべてのリクエストには、Cookie に保存される承認ハッシュが含まれています。これにより、XNUMX 種類のクライアントの動作ロジックをさらに分離し、正しい回答を与えることができます。
そうですね、「site.com/@UserName」のようなクエリを動的に生成されるユーザー ページに変換するという、別のモジュールに組み込む価値のある小さくて優れた機能です。 リクエストの処理後、次のモジュールが機能します。
第3章 ステアリングホイールの取り付け、チェーンの注油
パーサーが作業を完了するとすぐにハンドラーが動作し、サーバーにさらに指示を与え、制御を XNUMX つの部分に分割します。
単純なハンドラー
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);
            };
        }
    }
}
実際、ユーザー認証のチェックは XNUMX 回だけで、その後リクエストの処理が開始されます。
クライアントコントローラー

ユーザーが認可されていない場合、そのユーザーの機能はユーザー プロファイルの表示と認可登録ウィンドウのみに基づいています。 許可されたユーザーのコードはほぼ同じなので、複製する理由はありません。
不正なユーザー
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;
            }
        }
    }

}



そしてもちろん、ユーザーは何らかのページ コンテンツを受信する必要があるため、応答については、リソース要求への応答を担当する次のモジュールがあります。
ライターコントローラー
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();

}

}

}

しかし、ユーザーに自分のプロフィールと他のユーザーのプロフィールを表示するために、RazorEngine またはその一部を使用することにしました。 これには、無効なリクエストの処理と適切なエラー コードの発行も含まれます。
かみそりコントローラー
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();
            }
        }
    }
}

そしてもちろん、許可されたユーザーの検証が機能するには、許可が必要です。 認可モジュールはデータベースと対話します。 サイト上のフォームから受信したデータはコンテキストから解析され、ユーザーは保存され、その代わりに Cookie を受け取り、サービスにアクセスします。
認可モジュール
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);

}

}

}

}



データベース処理は次のようになります。
データベース
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;

}

}

}

}


そして、すべてが時計仕掛けのように機能し、承認と登録の作業が行われ、サービスにアクセスするための最小限の機能がすでに存在しており、アプリケーションを作成して、すべてを実行する主要な機能と全体を結び付ける時期が来ています。
第4章 自転車を捨てる
3 つのプラットフォームで XNUMX つのアプリケーションを作成する人件費を削減するために、Xamarin.Forms でクロスプラットフォームを作成することにしました。 繰り返しますが、C# であるという事実のおかげです。 サーバーにデータを送信するだけのテスト アプリケーションを作成したところ、興味深い点に気づきました。 デバイスからのリクエストについては、楽しみのために HttpClient に実装し、JSON 形式の認証フォームからのデータを含む HttpRequestMessage サーバーに送信しました。 特に何も期待せずにサーバー ログを開くと、デバイスからのリクエストとすべてのデータが記録されていました。 わずかな昏迷、気だるい夜の中で過去XNUMX週間に行われたすべてのことを意識します。 送信されたデータの正確性を確認するために、HttpListner上にテストサーバーを構築しました。 すでに別のリクエストを受け取っていたので、それを数行のコードで分解し、フォームからデータの KeyValuePair を受け取りました。 クエリの解析は XNUMX 行に減りました。
先ほどは触れていませんでしたが、以前のサーバーでは WebSocket 上に構築されたチャットも実装して、さらにテストを開始しました。 これは非常にうまく機能しましたが、Tcp を介した対話の原理自体が憂鬱で、通信ログを使用して 6455 人のユーザーの対話を適切に構築するには、あまりにも多くの不必要な作業を行う必要がありました。 これには、接続を切り替えるリクエストの解析と RFC XNUMX プロトコルを使用したレスポンスの収集が含まれるため、テスト サーバーでは単純な WebSocket 接続を作成することにしました。 ただの楽しみのためです。
チャットに接続する
 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();
                        }
                    }
                }
            }
        }

そしてそれはうまくいきました。 サーバー自体が接続を構成し、応答キーを生成しました。 SSL 経由でサーバー登録を個別に構成する必要さえなく、システムの必要なポートに証明書がすでにインストールされていれば十分でした。
デバイス側とサイト側で、200 つのクライアントがメッセージを交換し、これがすべて記録されました。 サーバーの速度を低下させる巨大なパーサーはなく、これらはどれも必要ありませんでした。 応答時間は 40 ミリ秒から 30 ～ XNUMX ミリ秒に短縮されました。 そして私は唯一正しい決断に至りました。

Tcp 上の現在のサーバー実装を破棄し、Http の下にあるものをすべて書き換えます。 現在、プロジェクトは再設計段階にありますが、まったく異なる相互作用の原則に従っています。 デバイスとサイトの動作は同期してデバッグされ、共通のコンセプトを持っています。唯一の違いは、デバイス用の HTML ページを生成する必要がないことです。
出力
「浅瀬を知らないなら、水に入らないでください」 仕事を始める前に、目標や目的をもっと明確に定義し、さまざまなクライアントに実装するために必要な技術や手法を徹底的に検討する必要があると思います。 プロジェクトはすでに完成に近づいていますが、私がどのようにして特定のものを保存したかについては、もう一度お話しするかもしれません。 開発プロセス中に多くのことを学びましたが、将来的にはさらに多くのことを学ぶ必要があります。 ここまで読んでいただいた方、ありがとうございます。
出所： habr.com

C# .Net フレームワークに基づく高度なサイクリングまたはクライアントサーバーアプリケーション

エントリー

パート 1. フレームのプロトタイピング

第 2 章ホイールのネジ止め

第3章ステアリングホイールの取り付け、チェーンの注油

第4章自転車を捨てる

出力

C# .Net フレームワークに基づく高度なサイクリングまたはクライアントサーバー アプリケーション

エントリー

パート 1. フレームのプロトタイピング

第 2 章 ホイールのネジ止め

第3章 ステアリングホイールの取り付け、チェーンの注油

第4章 自転車を捨てる

出力

C# .Net フレームワークに基づく高度なサイクリングまたはクライアントサーバーアプリケーション

第 2 章ホイールのネジ止め

第3章ステアリングホイールの取り付け、チェーンの注油

第4章自転車を捨てる