🐨 ⌚️ 👩🏻‍⚖️ .NET: मॉनिटरिंग और सर्वर मैनेजमेंट के लिए एक्स्टेंसिबल प्लग-इन सिस्टम बनाना 🏼 👊🏿 📣

नमस्कार, मैं आपको एक ऐसी परियोजना के बारे में बताना चाहता हूं, जो मेरी राय में, बहुत दिलचस्प है और, संभवतः, किसी के लिए उपयोगी है।

कार्य प्लगइन्स के साथ सिस्टम को एक्स्टेंसिबल बनाना था जो विभिन्न लोगों द्वारा लिखा जाएगा। प्लग-इन को सर्वर (प्रदर्शन, स्थापित कार्यक्रमों के संस्करण, डेटाबेस से चयन), या कुछ बदलाव (सेवाओं को फिर से शुरू करने, आदि) से जानकारी एकत्र करनी चाहिए। सर्वरों के साथ संचार को टीसीपी प्रोटोकॉल और एक विशिष्ट पोर्ट के माध्यम से किया जाना चाहिए। परिणाम HTML पृष्ठों पर प्रदर्शित होने चाहिए। विभिन्न शहरों में कई सर्वर हैं, कनेक्शन बहुत खराब है, सर्वर बहुत उत्पादक नहीं हैं, सॉफ्टवेयर को दिन में 10 बार अपडेट किया जा सकता है, सामान्य तौर पर, उनके प्रदर्शन पर कुल नियंत्रण की आवश्यकता होती है।

तर्क करने के बाद, यह निर्णय लिया गया:

एक सेवा बनाएं और प्रत्येक सर्वर पर स्थापित करें;
सेवा को ब्राउज़र अनुरोधों के लिए पोर्ट पर सुनना चाहिए;
प्लगइन्स को ब्राउज़र से सर्वर पते पर भी जोड़ा और अद्यतन किया जाना चाहिए (उदा। http: //10.14.3.160/);
प्लगइन्स को JSON मार्कअप में जानकारी वापस देनी चाहिए यदि परिणाम एक वस्तु है, और HTML परिणाम है तो पाठ;
प्लगइन को सर्वर के पते (http://10.14.3.160/pluginname) में उसका नाम जोड़कर बुलाया जाता है और मापदंडों को उसी तरीके से प्रेषित किया जाता है (http://10.14.3.160/pluginName?p1/5&p2=8&p3=somevalue);
जावास्क्रिप्ट और jQuery का उपयोग करके HTML पृष्ठों पर जानकारी का मिश्रण
.Net 2.0 पर सिस्टम लिखें, क्योंकि केवल सभी सर्वर पर यह संस्करण स्थापित है। सी # भाषा।

विकास IPlugin इंटरफ़ेस के विवरण के साथ शुरू हुआ:

namespace Interface { public interface IPlugin { string Name { get; } string Version { get; } string Author { get; } object Data(Dictionary<string, string> query); } }

जहां डेटा () फ़ंक्शन है जिसे सेवा ब्राउज़र के अनुरोध पर कॉल करेगी। और क्वेरी में पैरामीटर होंगे।

अगला कदम एक सेवा बनाना है:

सेवा शुरू करते समय, हम एप्लिकेशन फ़ोल्डर में DLL फ़ाइलों (प्लगइन्स) की तलाश करते हैं, और जांचते हैं कि क्या वे IPlugin इंटरफ़ेस को लागू करते हैं। यदि ऐसा है, तो प्लगइन्स की सूची में जोड़ें।
पोर्ट की बात सुनकर
यदि कोई अनुरोध है, और इसमें कोई निकाय शामिल नहीं है, तो हम url पते को संसाधित करते हैं। यदि पते में एक उपनिर्देशिका है, तो हम एक ही नाम के साथ प्लगइन की तलाश करते हैं, इसके डेटा () फ़ंक्शन को कॉल करते हैं और इसमें हम ब्राउज़र से प्राप्त मापदंडों को पास करते हैं, हम परिणाम की प्रतीक्षा कर रहे हैं। यदि फ़ंक्शन पाठ (प्रकार स्ट्रिंग) लौटाता है, तो हम इसे उस तरह ब्राउज़र को पास करते हैं, यदि नहीं, तो हम इसे JSON मार्कअप में परिवर्तित करते हैं, और इसे ब्राउज़र को भी पास करते हैं। यदि पते में एक उपनिर्देशिका नहीं है, तो हम ब्राउज़र को प्लग इन की एक सूची वाले पृष्ठ पर स्थानांतरित करते हैं और सर्वर पर एक नया डाउनलोड करने के लिए एक बटन।
यदि कोई अनुरोध है, लेकिन इसमें एक निकाय शामिल है - हम जांचते हैं, तो शायद वे हमें प्लगइन पास करते हैं। यदि ऐसा है, तो इसे एप्लिकेशन फ़ोल्डर में सहेजें, और प्लगइन्स की सूची में जोड़ें या बदलें।
हम बंदरगाह पर सुनना जारी रखते हैं।

इस एल्गोरिथ्म के कार्यान्वयन

 class HostServer : IDisposable { private Thread mThread; private HttpListener listener; private static string sVersion { get; set; } private static string sName { get; set; } private static string sIPAdress { get; set; } private static List<IPlugin> sPlugins { get; set; } public HostServer(int port) { sVersion = "0.6"; sName = "ISHOST"; sIPAdress = "http://" + System.Net.Dns.GetHostEntry(System.Net.Dns.GetHostName()).AddressList[0].ToString() + ":" + port.ToString() + "/"; LoadPlugins(); listener = new HttpListener(); listener.Prefixes.Add(sIPAdress); } private static void LoadPlugins() { try { sPlugins = new List<IPlugin>(); string folder = System.AppDomain.CurrentDomain.BaseDirectory; string[] files = System.IO.Directory.GetFiles(folder, "*.dll"); foreach (string file in files) { IPlugin plugin = IsPlugin(file); if (plugin != null) sPlugins.Add(plugin); } } catch (Exception e) { ToLog(e.Message); } } private static IPlugin IsPlugin(byte[] file) { try { System.Reflection.Assembly assembly = System.Reflection.Assembly.Load(file); foreach (Type type in assembly.GetTypes()) { Type iface = type.GetInterface("Interface.IPlugin"); if (iface != null) { IPlugin plugin = (IPlugin)Activator.CreateInstance(type); return plugin; } } } catch (Exception e) { ToLog(e.Message); } return null; } private static IPlugin IsPlugin(string file_url) { try { byte[] b = System.IO.File.ReadAllBytes(file_url); return IsPlugin(b); } catch (Exception e) { ToLog(e.Message); } return null; } public void Start() { mThread = new Thread(new ThreadStart(delegate() { try { listener.Start(); ToLog("Started on " + sIPAdress); while (true) { IAsyncResult result = listener.BeginGetContext(new AsyncCallback(ListenerCallback), listener); result.AsyncWaitHandle.WaitOne(); } } catch (Exception e) { if (e.GetType() != typeof(ObjectDisposedException)) ToLog(e.Message); } })); mThread.Start(); } public void Stop() { if (listener != null) listener.Close(); if (mThread != null) mThread.Join(10000); ToLog("Stoped"); } public static void ListenerCallback(IAsyncResult result) { try { HttpListener listener = (HttpListener)result.AsyncState; HttpListenerContext context = listener.EndGetContext(result); HttpListenerRequest request = context.Request; HttpListenerResponse response = context.Response; using (System.IO.Stream output = response.OutputStream) { if (request.HasEntityBody) { SaveNewPlugin(request.InputStream, response, output); } else { string ans = string.Empty; foreach (IPlugin plugin in sPlugins) { if (request.Url.LocalPath.Replace("/", "").ToLower().StartsWith(plugin.Name.ToLower())) { // Get Parameters from url Dictionary<string, string> query = new Dictionary<string, string>(); for (int i = 0; i < request.QueryString.Keys.Count; i++) { string pName = request.QueryString.Keys[i]; string pValue = Encoding.UTF8.GetString(request.ContentEncoding.GetBytes(request.QueryString[pName])); query.Add(pName, pValue); } //Get data from plugin try { object data = plugin.Data(query); if (data.GetType() == typeof(string)) { ans = (string)data; } else { //Convert data to JSON type ans = request.QueryString["callback"] + "(" + ConvertToJSON(data) + ")"; } } catch (Exception e) { ans = e.Message; } break; } } if (string.IsNullOrEmpty(ans)) { ans = GetMainPage(); } //Send data to user SendMessage(response, output, ans); output.Flush(); output.Close(); } } } catch (Exception e) { if (e.GetType() != typeof(ObjectDisposedException)) ToLog(e.Message); } } private static string GetMainPage() { StringBuilder sb = new StringBuilder(); sb.Append("<html>"); sb.Append("<head>"); sb.Append("<title>ISHOST " + sVersion + "</title>"); sb.Append("</head>"); sb.Append("<body>"); sb.Append("<table cellpadding=\"10px\">"); sb.Append("<thead>"); sb.Append("<tr>"); sb.Append("<td>"); sb.Append("<b>NAME</b>"); sb.Append("</td>"); sb.Append("<td>"); sb.Append("<b>VERSION</b>"); sb.Append("</td>"); sb.Append("<td>"); sb.Append("<b>AUTHOR</b>"); sb.Append("</td>"); sb.Append("</tr>"); sb.Append("</thead>"); foreach (IPlugin plugin in sPlugins) { sb.Append("<tr>"); sb.Append("<td>"); sb.Append(plugin.Name); sb.Append("</td>"); sb.Append("<td>"); sb.Append(plugin.Version); sb.Append("</td>"); sb.Append("<td>"); sb.Append(plugin.Author); sb.Append("</td>"); sb.Append("</tr>"); } sb.Append("</table>"); sb.Append("<div>"); sb.Append("<form action=\"" + sIPAdress + "\" enctype=\"multipart/form-data\" method=\"post\">"); sb.Append("<input type=\"file\" name=\"somename\" size=\"chars\">"); sb.Append("<input type=\"submit\" value=\"Send\">"); sb.Append("</form>"); sb.Append("</div>"); sb.Append("</body>"); sb.Append("</html>"); return sb.ToString(); } private static void SendMessage(HttpListenerResponse response, Stream output, string ans) { byte[] buffer = System.Text.Encoding.UTF8.GetBytes(ans); response.ContentLength64 = buffer.Length; output.Write(buffer, 0, buffer.Length); } private static string ConvertToJSON(object data) { string result = string.Empty; try { result = JsonConvert.SerializeObject(data, Formatting.Indented); } catch (Exception e) { ToLog(e.Message); } return result; } static void ToLog(string text) { try { string folder = System.AppDomain.CurrentDomain.BaseDirectory; using (StreamWriter sw = new StreamWriter(folder + @"\Log.txt", true)) { sw.WriteLine(text+ " : " + DateTime.Now); } } catch { } } public void Dispose() { Stop(); } }

एक टिप्पणी, सेवा को फिर से शुरू किए बिना प्लगइन्स (DLL) को अपडेट करने के लिए, मैंने dll फ़ाइल से बाइट्स पढ़े, लेकिन मैंने फ़ाइल को मेमोरी में लोड नहीं किया। इसके अलावा, मैंने इंटरफ़ेस के कार्यान्वयन के लिए रीड बाइट्स की जाँच की। यह विधि मुझे स्मृति से एक खुली डीएल के समय लेने वाली अनलोडिंग से बेहतर लग रही थी।
JSON मार्कअप में वस्तुओं का रूपांतरण न्यूटनसॉफ्ट लाइब्रेरी का उपयोग करके किया गया था।

पोर्ट पर सुनने के लिए सेवा कोड।

 class Program: ServiceBase { HostServer server; public Program() { this.ServiceName = "ISHOST"; server = new HostServer(28555); } protected override void OnStart(string[] args) { server.Start(); base.OnStart(args); } protected override void OnStop() { server.Stop(); base.OnStop(); } static void Main(string[] args) { System.ServiceProcess.ServiceBase.Run(new Program()); } }

सेवा संस्थापक

 [RunInstaller(true)] public class ISHOSTInstaller : Installer { public ISHOSTInstaller() { var processInstaller = new ServiceProcessInstaller(); var serviceInstaller = new ServiceInstaller(); processInstaller.Account = ServiceAccount.LocalSystem; serviceInstaller.DisplayName = "ISHOST"; serviceInstaller.StartType = ServiceStartMode.Automatic; serviceInstaller.ServiceName = "ISHOST"; this.Installers.Add(processInstaller); this.Installers.Add(serviceInstaller); } }

InstallUtil.exe सुविधा (InstallUtil ISHOST.exe) का उपयोग करके सर्वर पर सेवा स्थापित करने के बाद, हम सर्वर पते 10.14.3.160 : 28555 पर जाएंगे । यह पेज हमारे लिए खुलेगा:

एक प्लगइन बनाएँ

 class TestPlugin : IPlugin { public string Author { get { return "Yura"; } } public string Name { get { return "TestPlugin"; } } public string Version { get { return "0.1"; } } public object Data(Dictionary<string, string> query) { return "<h1>HELLO</h1>"; } }

संकलन के बाद, फिर से ब्राउज़र पर जाएं, और TestPlugin.dll प्लगइन चुनें:

"भेजें" बटन पर क्लिक करने के बाद।

प्लगइन TestPlugin को कॉल करें

अगले लेख में मैं लिखूंगा कि जावास्क्रिप्ट और jQuery का उपयोग करके जानकारी कैसे एकत्र की जाए, और स्रोतों को भी बताया जाए।
मुझे आपकी टिप्पणियों की प्रतीक्षा है।

.NET: मॉनिटरिंग और सर्वर मैनेजमेंट के लिए एक्स्टेंसिबल प्लग-इन सिस्टम बनाना