🚣 🏖️ ⚜️ भूमिकाओं और उदाहरणों के बीच संदेश 🕶️ 🤾🏿 🖖🏿

आज, आपका ध्यान AtContent.com सेवा के वास्तु समाधान पर लेखों की एक श्रृंखला से दूसरा लेख है।

AtContent.com सेवा पर काम करने की प्रक्रिया में, हमें एक भूमिका के भीतर उदाहरणों के साथ-साथ भूमिकाओं के बीच सिंक्रनाइज़ करने का कार्य मिला। एसडीके के मानक उपकरण कोड की दो पंक्तियों के साथ इस समस्या को हल नहीं करते हैं। इसलिए, हमने उदाहरणों के बीच संचार के लिए अपना समाधान विकसित किया है। यह आपको भूमिका के सभी उदाहरणों पर एक बार में या एक उदाहरण पर कार्य करने की अनुमति देता है, जिसे एक निश्चित तरीके से या यादृच्छिक रूप से चुना जाता है।

समाधान का सार HTTP पर रोल इंस्टेंस के बीच संवाद करना है। सुरक्षित रूप से ऐसा करने के लिए आपको भूमिका सेटिंग्स में एक समापन बिंदु बनाने की आवश्यकता है।

चित्रा 1. एक समापन बिंदु बनाना

बिंदु प्रकार आंतरिक है, और कुछ निर्लिप्त निजी पोर्ट निर्दिष्ट करें। यह आवश्यक है ताकि एक्सचेंज डेटा सेंटर के अंदर हो। जोड़ने के बाद, आप इस बिंदु को HTTP के माध्यम से एक्सेस कर सकते हैं और अनुरोध भेज सकते हैं।

एक उदाहरण पर अनुरोधों को संभालने के लिए, आपको वेब रोल में एक जेनेरिक हैंडलर जोड़ना होगा। यहाँ Communicator.ashx है

चित्रा 2. एक सामान्य हैंडलर बनाना

सिद्धांत रूप में, संदेश भेजने की व्यवस्था करना पहले से ही संभव है, लेकिन कुछ और समस्याओं का हल होना बाकी है।

पहली समस्या सुरक्षा की है। पहले जोड़ा हैंडलर बाहरी पते और पोर्ट पर उपलब्ध है। इसलिए, प्रवेश द्वार पर इसकी रक्षा करना आवश्यक है। सबसे आसान तरीका POST अनुरोध के लिए एक पैरामीटर जोड़ना है जो एक कुंजी के रूप में कार्य करेगा।

दूसरी समस्या उदाहरण के लिए आंतरिक समापन बिंदु तक पहुंच रही है। इसे हल करने के लिए, SDK एक अद्भुत उपकरण प्रदान करता है - ServiceRuntime। इसका उपयोग करने के लिए, आपको उपयुक्त नामस्थान कनेक्ट करने की आवश्यकता है:

using Microsoft.WindowsAzure; using Microsoft.WindowsAzure.ServiceRuntime;

उसके बाद, हम उन भूमिका उदाहरणों का चयन कर सकते हैं जिनकी हमें आवश्यकता है और उनके लिए POST अनुरोध भेजें:

 //   var Params = new Dictionary<string, string>(); Params["key"] = "key_value"; //   POST- string STDIN = ""; foreach (var Item in Params) { STDIN += Item.Key + "=" + HttpUtility.UrlEncode(Item.Value, Encoding.UTF8) + "&"; } byte[] sentData = Encoding.UTF8.GetBytes(STDIN); foreach (RoleInstance roleInst in RoleEnvironment.Roles["WebRole1"].Instances) { // WebRequest    WebRequest reqPOST = WebRequest.Create( "http://" + roleInst.InstanceEndpoints["InterEndpoint"].IPEndpoint + "/Communicator.ashx"); reqPOST.Method = "POST"; reqPOST.Timeout = 120000; reqPOST.ContentType = "application/x-www-form-urlencoded"; //  reqPOST.ContentLength = sentData.Length; System.IO.Stream sendStream = reqPOST.GetRequestStream(); sendStream.Write(sentData, 0, sentData.Length); sendStream.Close(); System.Net.WebResponse resp = reqPOST.GetResponse(); System.IO.Stream stream = resp.GetResponseStream(); System.IO.StreamReader sr = new StreamReader(stream); string s = sr.ReadToEnd(); }

यह उदाहरण दिखाता है कि एक ही बार में WebRole1 भूमिका के सभी उदाहरणों के लिए अनुरोध कैसे भेजें। आप शब्दकोश पैरामीटर में अतिरिक्त पैरामीटर जोड़ सकते हैं जो कार्य को संसाधित करने में शामिल होंगे।

यदि आप किसी विशिष्ट उदाहरण के लिए, या किसी यादृच्छिक के लिए कार्य भेजना चाहते हैं, तो बस रोलइन्वायरमेंट से उदाहरण चुनें।

उसी समय, Communicator.ashx में, हमारे लिए यह POST अनुरोध संसाधित करने और आवश्यक आदेशों को निष्पादित करने के लिए बना रहता है:

 //    if (context.Request.Form["key"] != "key_value") return; //

हमारी सेवा में सबसे आम परिदृश्य उदाहरण कैश बदल रहा है।

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

 private HttpListener listener = null; private AutoResetEvent connectionWaitHandle = new AutoResetEvent(false); public override void Run() { //      HttpListener Thread HttpListenerThread = null; while (true) { if (HttpListenerThread == null) { HttpListenerThread = new Thread(new ThreadStart(HttpListenerHandler)); HttpListenerThread.IsBackground = true; HttpListenerThread.Start(); } Thread.Sleep(1000); } } protected void HttpListenerHandler() { //   HttpListener     ServiceEndpoint if (listener == null) { listener = new HttpListener(); var HostEndpoint = RoleEnvironment.CurrentRoleInstance.InstanceEndpoints["ServiceEndpoint"].IPEndpoint.ToString(); listener.Prefixes.Add(string.Format("http://{0}/", HostEndpoint)); listener.Start(); } while (true) { IAsyncResult result = listener.BeginGetContext(HandleAsyncConnection, listener); connectionWaitHandle.WaitOne(); } } private void HandleAsyncConnection(IAsyncResult result) { // POST- HttpListener listener = (HttpListener)result.AsyncState; HttpListenerContext context = listener.EndGetContext(result); connectionWaitHandle.Set(); var Request = context.Request; var Response = context.Response; if (Request.HttpMethod == "POST") { Stream BodyStream = context.Request.InputStream; var encoding = context.Request.ContentEncoding; var reader = new StreamReader(BodyStream, encoding); var PostParams = HttpUtility.ParseQueryString(reader.ReadToEnd(), encoding); if (PostParams["key"] != "key_value") return; //  } Response.OutputStream.Close(); }

यहाँ WorkerRole.cs वर्ग के लिए कोड है, या यों कहें कि इसके जिस हिस्से में बदलाव आया है। यह ध्यान दिया जाना चाहिए कि प्रसंस्करण अनुरोधों के लिए, हमें System.Web नामस्थान की आवश्यकता है। आपको WorkerRole के लिए उपयुक्त संदर्भ भी जोड़ना होगा।

इस सब के बाद, हमें एक ही भूमिका के भीतर और भूमिकाओं के उदाहरणों के बीच दोनों उदाहरणों तक पहुंचने के लिए एक कार्य प्रणाली मिली। इस इंटरैक्शन का उपयोग करने के लिए बहुत सारे परिदृश्य हैं। मैं श्रृंखला के निम्नलिखित लेखों में उनमें से कुछ के बारे में बात करूंगा - "एक उदाहरण पर कैशिंग डेटा और कैशिंग का प्रबंधन करना" और "क्लाउड क्यू के प्रसंस्करण का कुशल प्रबंधन (कतार)"।

कुछ सुधारों के साथ लेख में वर्णित तंत्र विंडोज एज़्योर के लिए ओपनसोर्स सीपीएलएस लाइब्रेरी के हिस्से के रूप में उपलब्ध होगा, जो जल्द ही सार्वजनिक डोमेन में होगा।

श्रृंखला में पढ़ें:

भूमिकाओं और उदाहरणों के बीच संदेश

More articles: