🥁 💣 🎛️ C＃15分でマルチスレッドサーバー 🧛 ✌🏼 🧑🏼

C＃はかなりシンプルで柔軟な言語です。 .NETに加えて、既製のクラスがかなりあり、それによりさらに簡単になります。そのため、単純なマルチスレッドHTTPサーバーを記述して、わずか15分で静的コンテンツをレンダリングすることが可能です。既製のHttpListenerクラスを使用して、さらに高速に管理することもできますが、この記事の目標は、C＃でこのようなことを行う方法を示すことです。

最初に、新しいコンソールプロジェクトを作成します。

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

Copy Source | Copy HTML using System; using System.Collections.Generic; using System.Text; namespace HTTPServer { class Server { static void Main( string [] args) { } } }

.NETでは、TcpListenerクラスを使用してTCPサーバーを非常に簡単に作成できます。これを使用します。

Copy Source | Copy HTML

クラスサーバー
{
TcpListenerリスナー。 // TCPクライアントを受け入れるオブジェクト
//サーバーの起動
パブリックサーバー（ intポート）
{
//指定されたポートの「リスナー」を作成します
リスナー= 新しい TcpListener （IPAddress.Any、ポート）;
Listener.Start（）; //実行する
//無限ループ内
while （ true ）
{
//新しい顧客を受け入れる
Listener.AcceptTcpClient（）;
}
}
//サーバーを停止します
〜サーバー（）
{
//「リスナー」が作成された場合
if （リスナー！= null ）
{
//やめて
Listener.Stop（）;
}
}
static void Main（ string [] args）
{
//ポート80に新しいサーバーを作成します
新しいサーバー（ 80 ）;
}
}

ここでアプリケーションを実行すると、すでにポート80に接続できます...それだけです。接続は、ハンドラが見つからず、サーバー側で閉じないため、何もせずにアイドル状態になります。

最も簡単なハンドラーを作成しましょう。

Copy Source | Copy HTML

//クライアントハンドラクラス
クラスのクライアント
{
//クラスのコンストラクター。彼はTcpListenerから受信したクライアントを転送する必要があります
パブリッククライアント（TcpClient クライアント）
{
//シンプルなHTMLページのコード
string Html = "<html> <body> <h1>動作します！</ h1> </ body> </ html>" ;
//必須のヘッダー：サーバーの応答、コンテンツのタイプと長さ。 2行の空行の後-コンテンツ自体
string Str = "HTTP / 1.1 200 OK \ nContent-type：text / html \ nContent-Length：" + Html.Length.ToString（）+ "\ n \ n" + Html;
//文字列をバイト配列にキャストします
byte [] Buffer = Encoding.ASCII.GetBytes（Str）;
//クライアントに送信します
Client .GetStream（）。Write（ Buffer 、 0 、 Buffer .Length）;
//接続を閉じます
クライアント .Close（）;
}
}

クライアントを渡すには、Serverクラスの1行を変更する必要があります。

Copy Source | Copy HTML

//新しいクライアントを受け入れ、処理のためにそれらをClientクラスの新しいインスタンスに転送します
新しいクライアント（Listener.AcceptTcpClient（））;

これで、プログラムを実行し、ブラウザでアドレス127.0.0.1を開き、大文字で「It works！」と表示できます。

HTTPリクエストパーサーの作成を開始する前に、サーバーをマルチスレッド化します。これを行うには、クライアントごとに新しいスレッドを手動で作成する方法と、スレッドプールを使用する方法の2つがあります。どちらの方法にも長所と短所があります。クライアントごとにストリームを作成すると、サーバーは高負荷に耐えられない可能性がありますが、ほぼ無制限の数のクライアントで同時に作業できます。スレッドプールを使用する場合、同時に実行されるスレッドの数は制限されますが、古いスレッドが完了するまで新しいスレッドを作成することはできません。どちらの方法がより適しているかはわかりませんので、両方の例を示します。

Clientクラスの新しいインスタンスのみを作成する単純なスレッドプロシージャを作成します。

Copy Source | Copy HTML

static void ClientThread（ Object StateInfo）
{
新しいクライアント（（TcpClient）StateInfo）;
}

最初の方法を使用するには、無限の顧客受付サイクルの内容を置き換えるだけです。

Copy Source | Copy HTML

//新しいクライアントを受け入れます
TcpClient Client = Listener.AcceptTcpClient（）;
//ストリームを作成します
スレッドスレッド = 新しいスレッド（新しい ParameterizedThreadStart （ClientThread））;
//そして、このスレッドを実行し、受信したクライアントに渡します
Thread .Start（クライアント）;

2番目の方法では、同じことを行う必要があります。

Copy Source | Copy HTML

//新しい顧客を受け入れます。クライアントが受け入れられた後、新しいスレッド（ClientThread）に転送されます
//スレッドプールを使用します。
ThreadPool.QueueUserWorkItem（ new WaitCallback （ClientThread）、Listener.AcceptTcpClient（））;

さらに、同時に実行されるスレッドの最大数と最小数を設定する必要があります。これはメイン手順で行います：

Copy Source | Copy HTML

//必要な最大スレッド数を定義します
//プロセッサごとに4つあります
int MaxThreadsCount = Environment .ProcessorCount * 4 ;
//ワーカースレッドの最大数を設定します
ThreadPool.SetMaxThreads（MaxThreadsCount、MaxThreadsCount）;
//ワーカースレッドの最小数を設定します
ThreadPool.SetMinThreads（ 2、2 ）;

この数にはメインスレッドが含まれるため、スレッドの最大数は少なくとも2でなければなりません。ユニットを設定すると、メインスレッドが作業を中断した場合にのみクライアント処理が可能になります（たとえば、新しいクライアントを待機したり、Sleepプロシージャが呼び出されたりします）。

したがって、完全にClientクラスに切り替えて、HTTP要求の処理を開始します。クライアントからリクエストテキストを取得します。

Copy Source | Copy HTML

//クライアントリクエストを保存する行を宣言します
文字列 Request = "" ;
//クライアントから受信したデータを保存するバッファ
byte [] Buffer = 新しいバイト [ 1024 ];
//クライアントから受信したバイト数を格納する変数
intカウント;
//クライアントストリームからデータを受信するまで読み取ります
while （（Count = Client.GetStream（）。Read（ Buffer 、 0 、 Buffer .Length））> 0 ）
{
//このデータを文字列に変換し、リクエスト変数に追加します
リクエスト+ = Encoding.ASCII.GetString（ Buffer 、 0 、Count）;
//リクエストは、シーケンス\ r \ n \ r \ nで中断する必要があります
//リクエスト行の長さが4キロバイトを超える場合、データ受信を自分で中断します
// POSTリクエスト（など）からデータを受信する必要はありませんが、定期的なリクエスト
//理論的には4キロバイトを超えてはいけません
if （Request.IndexOf（ "\ r \ n \ r \ n" ）> = 0 || Request.Length> 4096 ）
{
休憩 ;
}
}

次に、受信したデータを解析します。

Copy Source | Copy HTML

//正規表現を使用してクエリ文字列を解析します
//同時に、GETリクエストのすべての変数をカットします
ReqMatch = Regexに一致します。 Match （リクエスト、 @ "^ \ w + \ s +（[^ \ s \？] +）[^ \ S] * \ s + HTTP /.* |" ）;
//リクエストが失敗した場合
if （ReqMatch == Match .Empty）
{
//クライアントにエラー400を渡す-無効なリクエスト
SendError（クライアント、 400 ）;
帰る
}
//クエリ文字列を取得します
string RequestUri = ReqMatch.Groups [ 1 ] .Value;
//エスケープされた文字を変換して、元の形式に縮小します
//たとえば、「％20」->「」
RequestUri = Uri .UnescapeDataString（RequestUri）;
//行にコロンが含まれる場合、エラー400を送信します
//これは、http：//example.com/../../file.txtなどのURLから保護するために必要です。
if （RequestUri.IndexOf（ ".." ）> = 0 ）
{
SendError（クライアント、 400 ）;
帰る
}
//クエリ行が「/」で終わる場合、index.htmlを追加します
if （RequestUri.EndsWith（ "/" ））
{
RequestUri + = "index.html" ;
}

最後に、ファイルを操作します。ファイルがあるかどうかを確認し、そのコンテンツタイプを判別して、クライアントに渡します。

Copy Source | Copy HTML

文字列 FilePath = "www /" + RequestUri;
//このファイルがwwwフォルダーに存在しない場合、404エラーを送信します
if （！ File .Exists（FilePath））
{
SendError（クライアント、 404 ）;
帰る
}
//クエリ文字列からファイル拡張子を取得します
string Extension = RequestUri.Substring（RequestUri.LastIndexOf（ '。' ））;
//コンテンツタイプ
string ContentType = "" ;
//ファイル拡張子によってコンテンツのタイプを判別しようとしています
スイッチ（拡張機能）
{
ケース ".htm" ：
ケース ".html" ：
ContentType = "text / html" ;
休憩 ;
ケース「.css」：
ContentType = "text / stylesheet" ;
休憩 ;
ケース「.js」：
ContentType = "text / javascript" ;
休憩 ;
ケース ".jpg" ：
ContentType = "image / jpeg" ;
休憩 ;
ケース「.jpeg」：
ケース ".png" ：
ケース ".gif" ：
ContentType = "image /" + Extension.Substring（ 1 ）;
休憩 ;
デフォルト：
if （Extension.Length> 1 ）
{
ContentType = "application /" + Extension.Substring（ 1 ）;
}
他に
{
ContentType = "application / unknown" ;
}
休憩 ;
}
//エラーを防ぐためにファイルを開きます
FileStream FS;
試してみる
{
FS = new FileStream （FilePath、FileMode.Open、FileAccess.Read、FileShare.Read）;
}
catch （例外）
{
//エラーが発生した場合、クライアントに500エラーを送信します
SendError（クライアント、 500 ）;
帰る
}
//ヘッダーを送信します
string Headers = "HTTP / 1.1 200 OK \ nContent-Type：" + ContentType + "\ nContent-Length：" + FS.Length + "\ n \ n" ;
byte [] HeadersBuffer = Encoding.ASCII.GetBytes（ヘッダー）;
Client.GetStream（）。Write（HeadersBuffer、 0 、HeadersBuffer.Length）;
//ファイルの終わりに達するまで
while （FS.Position <FS.Length）
{
//ファイルからデータを読み取ります
Count = FS.Read（ Buffer 、 0 、 Buffer .Length）;
//そしてそれらをクライアントに渡します
Client.GetStream（）。書き込み（ Buffer 、 0 、Count）;
}
//ファイルと接続を閉じます
FS.Close（）;
Client.Close（）;

コードには、まだ説明されていないSendErrorプロシージャも記載されています。それも書きましょう：

Copy Source | Copy HTML

//エラーページを送信する
private void SendError（TcpClientクライアント、 intコード）
{
//「200 OK」形式の文字列を取得します
// HttpStatusCodeはすべてのHTTP / 1.1ステータスコードを保存します
string CodeStr = Code.ToString（）+ "" +（（HttpStatusCode）Code）.ToString（）;
//シンプルなHTMLページのコード
string Html = "<html> <body> <h1>" + CodeStr + "</ h1> </ body> </ html>" ;
//必須のヘッダー：サーバーの応答、コンテンツのタイプと長さ。 2行の空行の後-コンテンツ自体
string Str = "HTTP / 1.1" + CodeStr + "\ nContent-type：text / html \ nContent-Length：" + Html.Length.ToString（）+ "\ n \ n" + Html;
//文字列をバイト配列にキャストします
byte [] Buffer = Encoding.ASCII.GetBytes（Str）;
//クライアントに送信します
Client.GetStream（）。Write（ Buffer 、 0 、 Buffer .Length）;
//接続を閉じます
Client.Close（）;
}

これで、簡単なHTTPサーバーの作成が完了しました。いくつかのスレッドで機能し、静的なものを提供し、不正な要求に対する単純な保護を備えており、欠落ファイルを誓います。これらはすべて、追加のガジェットでハングアップできます。ドメインの構成、処理、mod_rewriteなどのアドレスの変更、CGIのサポートなどです。しかし、これはまったく別の話になります:-)

ソース（ThreadPool経由）

ソース（スレッド経由）

ソース付きアーカイブ（ThreadPool経由、スレッド経由のオプションはコメント化されています）

コンパイル済みバージョンのアーカイブ（ThreadPool経由）

C＃15分でマルチスレッドサーバー

More articles: