🤴🏼 🚺 🙍🏼 सी # मल्टीथ्रेडेड सर्वर 15 मिनट में 🔋 🉐 👨‍🚒

C # काफी सरल और लचीली भाषा है। .NET के साथ-साथ, कुछ तैयार कक्षाएं हैं, जो इसे और भी आसान बनाती हैं। इतना ही कि केवल 15 मिनट में स्थिर सामग्री को प्रस्तुत करने के लिए एक साधारण बहु-थ्रेडेड HTTP सर्वर लिखना संभव है। आप तैयार किए गए 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 वर्ग का उपयोग करके आसानी से एक टीसीपी सर्वर बना सकते हैं, जिसका हम उपयोग करेंगे:

Copy Source | Copy HTML
क्लास सर्वर
{
TcpListener श्रोता; // एक ऐसी वस्तु जो टीसीपी ग्राहकों को स्वीकार करती है
// सर्वर प्रारंभ
सार्वजनिक सर्वर ( इंट पोर्ट)
{
// निर्दिष्ट पोर्ट के लिए एक "श्रोता" बनाएं
श्रोता = नया TcpListener (IPAddress.Any, Port);
श्रोता.शर्त (); // इसे चलाएं
// एक अनंत लूप में
जबकि ( सच )
{
// नए ग्राहकों को स्वीकार करें
श्रोता। एसेप्टकैपक्लियेंट ();
}
}
// सर्वर बंद करो
~ सर्वर ()
{
// यदि "श्रोता" बनाया गया था
अगर (श्रोता! = अशक्त )
{
// इसे रोकें
श्रोता.समर्थन ();
}
}
स्थिर शून्य मुख्य ( स्ट्रिंग [] args)
{
// पोर्ट 80 पर एक नया सर्वर बनाएं
नया सर्वर ( 80 );
}
}

यदि आप अभी एप्लिकेशन चलाते हैं, तो आप पहले से ही पोर्ट 80 से कनेक्ट कर सकते हैं और ... यही है। कनेक्शन केवल कुछ भी बेकार नहीं होगा, क्योंकि इसका हैंडलर गायब है और यह सर्वर साइड पर बंद नहीं होता है।
आइए सबसे सरल हैंडलर लिखते हैं:

Copy Source | Copy HTML
// क्लाइंट हैंडलर क्लास
क्लास क्लाइंट
{
// क्लास कंस्ट्रक्टर। उसे प्राप्त क्लाइंट को TcpListener से ट्रांसफर करना होगा
सार्वजनिक ग्राहक (TcpClient ग्राहक )
{
// एक साधारण HTML पेज के लिए कोड
string Html = "<html> <body> <h1> यह काम करता है! </ h1> </ body> </ html>" ;
// आवश्यक हेडर: सर्वर प्रतिक्रिया, प्रकार और सामग्री की लंबाई। दो खाली लाइनों के बाद - सामग्री ही
string Str = "HTTP / 1.1 200 ओके \ n कॉन्टेंट-टाइप: टेक्स्ट / html \ n कॉन्टेंट -लेंथ:" + Html.Length.ToString () + "\ n \ n" + एचटीएमएल;
// बाइट सरणी के लिए स्ट्रिंग कास्ट करें
बाइट [] बफ़र = एनकोडिंग .ASCII.GetBytes (Str);
// इसे क्लाइंट को भेजें
ग्राहक .GetStream ()। लिखें ( बफर , 0 , बफर। गति);
// कनेक्शन बंद करें
ग्राहक .Close ();
}
}

इसके लिए क्लाइंट को पास करने के लिए, आपको सर्वर क्लास में एक लाइन बदलने की जरूरत है:

Copy Source | Copy HTML
// हम नए ग्राहकों को स्वीकार करते हैं और उन्हें ग्राहक वर्ग के एक नए उदाहरण के लिए प्रसंस्करण के लिए स्थानांतरित करते हैं
नए ग्राहक (श्रोता। एसेप्टकैपक्लियर ());

अब आप प्रोग्राम को चला सकते हैं, ब्राउज़र में पता 127.0.0.1 खोलें और बड़े अक्षरों में देखें "यह काम करता है!"
इससे पहले कि हम HTTP अनुरोध पार्सर लिखना शुरू करें, हम अपने सर्वर को मल्टीथ्रेडेड बना देंगे। ऐसा करने के दो तरीके हैं: प्रत्येक क्लाइंट के लिए मैन्युअल रूप से एक नया थ्रेड बनाएं या थ्रेड पूल का उपयोग करें। दोनों तरीकों के अपने फायदे और नुकसान हैं। यदि आप प्रत्येक क्लाइंट के लिए एक स्ट्रीम बनाते हैं, तो सर्वर उच्च भार का सामना नहीं कर सकता है, लेकिन आप एक ही समय में लगभग असीमित ग्राहकों के साथ काम कर सकते हैं। यदि आप थ्रेड पूल का उपयोग करते हैं, तो साथ-साथ चलने वाले थ्रेड्स की संख्या सीमित होगी, लेकिन जब तक आप पुराने नहीं होते तब तक आप एक नया थ्रेड नहीं बना सकते। आपके लिए कौन सी विधि अधिक उपयुक्त है, मुझे नहीं पता, इसलिए मैं दोनों का उदाहरण दूंगा।
हम एक सरल थ्रेड प्रक्रिया लिखेंगे जो केवल ग्राहक वर्ग का एक नया उदाहरण बनाएगी:

Copy Source | Copy HTML
स्थिर शून्य ग्राहक ( वस्तु स्थिति)
{
नया ग्राहक ((TcpClient) StateInfo);
}

पहली विधि का उपयोग करने के लिए, आपको केवल हमारे अंतहीन ग्राहक रिसेप्शन चक्र की सामग्री को बदलना होगा:

Copy Source | Copy HTML
// नए ग्राहक को स्वीकार करें
TcpClient ग्राहक = श्रोता। AcceptTcpClient ();
// एक स्ट्रीम बनाएं
थ्रेड थ्रेड = नया थ्रेड ( नया ParameterizedThreadStart (ClientThread));
// और इस धागे को चलाएं, इसे प्राप्त ग्राहक को पास करें
थ्रेड .Start (क्लाइंट);

दूसरी विधि के लिए, आपको ऐसा करने की आवश्यकता है:

Copy Source | Copy HTML
// नए ग्राहकों को स्वीकार करें। क्लाइंट द्वारा स्वीकार किए जाने के बाद, इसे एक नए थ्रेड में स्थानांतरित किया जाता है (ClientThread)
// थ्रेड पूल का उपयोग करना।
ThreadPool.QueueUserWorkItem ( नया WaitCallback (ClientThread), Listener.AcceptTcpClient ());

साथ ही, आपको एक साथ चलने वाले थ्रेड्स की अधिकतम और न्यूनतम संख्या निर्धारित करने की आवश्यकता है। हम इसे मुख्य प्रक्रिया में करते हैं:

Copy Source | Copy HTML
// धागे की आवश्यक अधिकतम संख्या को परिभाषित करें
// प्रत्येक प्रोसेसर के लिए 4 हो
int MaxThreadsCount = Environment .ProcessorCount * 4 ;
// कार्यकर्ता थ्रेड्स की अधिकतम संख्या निर्धारित करें
ThreadPool.SetMaxThreads (MaxThreadsCount, MaxThreadsCount);
// वर्कर थ्रेड्स की न्यूनतम संख्या निर्धारित करें
थ्रेडपूल। सेटमिनट्रेड्स ( 2 , 2 );

थ्रेड्स की अधिकतम संख्या कम से कम दो होनी चाहिए, क्योंकि इस नंबर में मुख्य थ्रेड शामिल है। यदि आप यूनिट सेट करते हैं, तो क्लाइंट प्रसंस्करण केवल तभी संभव होगा जब मुख्य धागा ने काम को निलंबित कर दिया हो (उदाहरण के लिए, एक नए ग्राहक की प्रतीक्षा करना या स्लीप प्रक्रिया को बुलाया गया है)।
तो, अब हम पूरी तरह से क्लाइंट क्लास पर जाएँगे और HTTP रिक्वेस्ट को प्रोसेस करना शुरू करेंगे। क्लाइंट से अनुरोध पाठ प्राप्त करें:

Copy Source | Copy HTML
// उस लाइन को डिक्लेयर करें जहां क्लाइंट रिक्वेस्ट स्टोर की जाएगी
स्ट्रिंग अनुरोध = "" ;
// क्लाइंट से प्राप्त डेटा को संग्रहीत करने के लिए बफर
बाइट [] बफ़र = नई बाइट [ 1024 ];
// क्लाइंट से प्राप्त बाइट्स की संख्या को संग्रहीत करने के लिए चर
इंट काउंट;
// क्लाइंट स्ट्रीम से पढ़ें जब तक कि डेटा इससे प्राप्त न हो
जबकि (काउंट = क्लाइंट.गेटस्ट्रीम ()। पढ़ें ( बफर , 0 , बफर। गति))> 0 )
{
// इस डेटा को एक स्ट्रिंग में परिवर्तित करें और इसे अनुरोध चर में जोड़ें
निवेदन + = Encoding.ASCII.GetString ( बफर , 0 , गणना);
// अनुरोध को अनुक्रम \ r \ n \ r \ n से टूटना चाहिए
// या तो हम स्वयं डेटा रिसेप्शन को बाधित करते हैं यदि अनुरोध रेखा की लंबाई 4 किलोबाइट से अधिक हो
// हमें POST अनुरोध (आदि) से डेटा प्राप्त करने की आवश्यकता नहीं है, लेकिन एक नियमित अनुरोध है
// सिद्धांत में 4 किलोबाइट से अधिक नहीं होना चाहिए
if (Request.IndexOf ( "\ r \ n \ r \ n" )> = 0 || अनुरोध। गति> 4096 )
{
तोड़ना ;
}
}

अगला, हम प्राप्त डेटा को पार्स करते हैं:

Copy Source | Copy HTML
// रेग्युलर एक्सप्रेशंस का उपयोग करके क्वेरी स्ट्रिंग को पार्स करें
// उसी समय, हमने GET अनुरोध के सभी चर काट दिए
मैच ReqMatch = Regex । मिलान (अनुरोध, @ "^ \ w + \ s + ([^ \ s \?] +) [^ \ S] * \ s + HTTP /.* |" );
// यदि अनुरोध विफल रहा
अगर (रीकमैच == मैच। खाली)
{
// क्लाइंट को त्रुटि 400 - अमान्य अनुरोध
SendError (क्लाइंट, 400 );
वापसी;
}
// क्वेरी स्ट्रिंग प्राप्त करें
string RequestUri = ReqMatch.Groups [ 1 ] .Value;
// इसे अपने मूल रूप में कम करें, बच गए वर्णों को परिवर्तित करना
// उदाहरण के लिए, "% 20" -> ""
RequestUri = Uri .UnescapeDataString (RequestUri);
// यदि रेखा में कोई कॉलन है, तो त्रुटि 400 भेजें
// http://example.com/../../file.txt जैसे URL से बचाव करना आवश्यक है
अगर (RequestUri.IndexOf ( ".." )> = 0 )
{
SendError (क्लाइंट, 400 );
वापसी;
}
// यदि क्वेरी लाइन "/" के साथ समाप्त होती है, तो इसमें index.html जोड़ें
अगर (RequestUri.EndsWith ( "/" ))
{
RequestUri + = "index.html" ;
}

और अंत में, हम फाइलों के साथ काम करेंगे: जांचें कि क्या कोई फाइल है, इसकी सामग्री प्रकार निर्धारित करें और इसे क्लाइंट को पास करें।

Copy Source | Copy HTML
string FilePath = "www /" + RequestUri;
// यदि यह फ़ाइल www फ़ोल्डर में मौजूद नहीं है, तो 404 त्रुटि भेजें
यदि ( फ़ाइल ! .Exists (FilePath))
{
SendError (ग्राहक, 404 );
वापसी;
}
// क्वेरी स्ट्रिंग से फ़ाइल एक्सटेंशन प्राप्त करें
string Extension = RequestUri.Substring (RequestUri.LastIndexOf ( '।' ));
// सामग्री प्रकार
string ContentType = "" ;
// फ़ाइल एक्सटेंशन द्वारा सामग्री के प्रकार को निर्धारित करने का प्रयास करना
स्विच (एक्सटेंशन)
{
मामला ".htm" :
मामला ".html" :
ContentType = "text / html" ;
तोड़ना ;
मामला ".css" :
कंटेंट टाइप = "टेक्स्ट / स्टाइलशीट" ;
तोड़ना ;
मामला ".js" :
ContentType = "text / javascript" ;
तोड़ना ;
मामला ".jpg" :
ContentType = "image / jpeg" ;
तोड़ना ;
मामला ".jpeg" :
मामला ".png" :
मामला ".gif" :
ContentType = "image /" + Extension.Substring ( 1 );
तोड़ना ;
डिफ़ॉल्ट :
अगर (Extension.Length> 1 )
{
ContentType = "application /" + Extension.Substring ( 1 );
}
अन्यथा
{
ContentType = "एप्लिकेशन / अज्ञात" ;
}
तोड़ना ;
}
// फ़ाइल खोलें, एक त्रुटि के खिलाफ बीमा
फाइलस्ट्रीम एफएस;
कोशिश
{
FS = नया FileStream (FilePath, FileMode.Open, FileAccess.Read, FileShare.Read);
}
पकड़ना ( अपवाद )
{
// यदि कोई त्रुटि होती है, तो क्लाइंट को 500 त्रुटि भेजें
SendError (ग्राहक, 500 );
वापसी;
}
// हेडर भेजें
string Headers = "HTTP / 1.1 200 OK \ nContent-Type:" + ContentType + "\ nContent- लंबाई:" + FS.Length + "\ n \ n" ;
बाइट [] हेडर्सबफ़र = एन्कोडिंग.एएससीआईआई.गेटबाइट्स (हेडर्स);
Client.GetStream ()। लिखें (हेडर्सबफ़र, 0 , हेडर्सबफ़र.लिफ्टर);
// फ़ाइल के अंत तक पहुँच गया है
जबकि (FS.Position <FS.Length)
{
// फ़ाइल से डेटा पढ़ें
गिनना = एफएस.हेड ( बफर , 0 , बफर। गति);
// और उन्हें क्लाइंट को पास करें
ग्राहक.गेटस्ट्रीम ()। लिखें ( बफर , 0 , गणना);
}
// फ़ाइल और कनेक्शन बंद करें
FS.Close ();
ग्राहक। क्लोज़ ();

कोड ने SendError प्रक्रिया का भी उल्लेख किया है जो अभी तक वर्णित नहीं है। आइए इसे भी लिखें:

Copy Source | Copy HTML
// त्रुटि पेज भेजना
निजी शून्य SendError ( TcpClient ग्राहक, इंट कोड)
{
// फॉर्म की एक स्ट्रिंग प्राप्त करें "200 ठीक है"
// HttpStatusCode सभी HTTP / 1.1 स्थिति कोड संग्रहीत करता है
string CodeStr = Code.ToString () + "" + ((HttpStatusCode) कोड) .ToString ();
// एक साधारण HTML पेज के लिए कोड
string Html = "<html> <body> <h1>" + CodeStr + "</ h1> </ body> </ html>" ;
// आवश्यक हेडर: सर्वर प्रतिक्रिया, प्रकार और सामग्री की लंबाई। दो खाली लाइनों के बाद - सामग्री ही
string Str = "HTTP / 1.1" + CodeStr + "\ n नियंत्रण-प्रकार: पाठ / html \ n नियंत्रण-लंबाई:" + Html.Length.ToString () + "\ n \ n" + Html;
// बाइट सरणी के लिए स्ट्रिंग कास्ट करें
बाइट [] बफ़र = एनकोडिंग .ASCII.GetBytes (Str);
// इसे क्लाइंट को भेजें
ग्राहक.गेटस्ट्रीम ()। लिखें ( बफर , 0 , बफर। गति);
// कनेक्शन बंद करें
ग्राहक। क्लोज़ ();
}

यह एक सरल HTTP सर्वर के लेखन को पूरा करता है। यह कई थ्रेड्स में काम करता है, स्थैतिक देता है, खराब अनुरोधों के खिलाफ सरल सुरक्षा करता है और लापता फाइलों पर शपथ लेता है। यह सब अतिरिक्त गैजेट के साथ लटका दिया जा सकता है: कॉन्फ़िगर करने की क्षमता, डोमेन को संसाधित करने, mod_rewrite जैसे पते बदलने, यहां तक कि CGI का समर्थन भी। लेकिन यह एक पूरी तरह से अलग कहानी होगी :-)

स्रोत (थ्रेडपूल के माध्यम से)
स्रोत (थ्रेड के माध्यम से)
पुरालेख स्रोत के साथ (थ्रेडपूल के माध्यम से, थ्रेड के माध्यम से विकल्प बाहर टिप्पणी की)
संकलित संस्करण संग्रह (थ्रेडपूल के माध्यम से)

सी # मल्टीथ्रेडेड सर्वर 15 मिनट में

More articles: