MSMQ के माध्यम से बिग बिज़टेल को मैसेज करना

कार्य का उदय हुआ: बिज़टाल के माध्यम से निर्देशिकाओं को वितरित करने के लिए, निर्देशिकाएं स्वयं काफी बड़ी हैं - 300 मेगाबाइट से अधिक। अतिरिक्त बड़े संदेश प्राप्त करने के लिए MSMQ का उपयोग करने का निर्णय लिया गया। और अब और अधिक विस्तार से यह करने के लिए क्या आवश्यक था।
बेशक, पहली चीज़ जो हो सकती है वह है MSDN पर एक उदाहरण ढूंढना कि यह सब कैसे लागू किया जाए (मैं इसे बाद में रूसी में एक साथ बदलावों के साथ वर्णन करूंगा), लेकिन मैं तुरंत एक आरक्षण कर दूंगा कि इस उदाहरण में एक छोटा सा है - आप उस हिस्से के आकार को समायोजित नहीं करेंगे जो संदेश में विभाजित है, जिसे हो सकता है विभिन्न कार्यों के लिए आवश्यक है। तो चलिए शुरू करते हैं।

विकास के लिए, हमें चाहिए:

• विजुअल स्टूडियो 2010 SP1
• Biztalk सर्वर 2010 SDK
• Biztalk सर्वर 2010 (परीक्षण के लिए)
• यह पता लगाने की इच्छा

प्रोजेक्ट को खोलें <Biztalk सर्वर 2010 SDK> \ AdaptersUsage \ MSMQLarge \ LargeMessages.sln के लिए पथ। हम देखते हैं कि समाधान में दो परियोजनाएं शामिल हैं: उनमें से एक सी ++ में, दूसरा सी # में। शुरू करने के लिए, हमें पहले एक को महसूस करने की आवश्यकता है। जिस आकार को हमारे संदेश को कतार में विभाजित किया गया है, उसे चुनने की क्षमता को कक्षा में सही करने की आवश्यकता है। जैसा कि आप स्रोत कोड से देख सकते हैं, आकार फ़ंक्शन में दिया गया है:

MQSendLargeMessage(unmanagedQueueData->queueHandle, &(messageData->message), MQ_SINGLE_MESSAGE, MQRTLARGE_USE_DEFAULT_PART_SIZE); 

डिफ़ॉल्ट रूप से, MQRTLARGE_USE_DEFAULT_PART_SIZE निश्चित रूप से शून्य पर सेट होता है, जिसका अर्थ है कि सर्वर के विवेक पर आकार का उपयोग करना। हमारे उद्देश्यों के लिए, हम निजी चर dwQueuePartSize को जोड़ेंगे और तदनुसार निजी फ़ंक्शन Init (...) को बदलेंगे।

 void Init(String* formatName, bool useAuthentication, DWORD dwQueuePartSize) { this->formatName = formatName; this->useAuthentication = useAuthentication; this->dwQueuePartSize=dwQueuePartSize; AllocUnmanagedQueueData(); } 

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

 LargeMessageQueue(String* formatName, bool useAuthentication) { Init(formatName, useAuthentication, 0); } LargeMessageQueue(String* formatName) { Init(formatName, false, 0); } 

अब हम अपने निर्माता को जोड़ सकते हैं जो उचित मूल्य लेता है:

 LargeMessageQueue(String* formatName, DWORD dwQueuePartSize) { Init(formatName, false, dwQueuePartSize); } LargeMessageQueue(String* formatName, bool useAuthentication, DWORD dwQueuePartSize) { Init(formatName, useAuthentication, dwQueuePartSize); } 

हमने एक मनमाना आकार निर्धारित करने में सक्षम होने के लिए दो मानक निर्माणकर्ताओं की नकल की। एक छोटी टिप्पणी: पहले से घोषित कंस्ट्रक्टरों के लिए एक पैरामीटर जोड़ना और इनिट मापदंडों को जोड़ना संभव होगा, लेकिन हम अन्य समाधानों के साथ पुस्तकालय की पिछड़ी संगतता खो देते हैं जो आप पहले से ही लागू कर चुके हैं, या हम इस पुस्तकालय के आधार पर तीसरे पक्ष के समाधान का उपयोग करते हैं।
इस स्तर पर, हमें उस कार्यक्षमता के साथ एक कार्यशील पुस्तकालय मिलता है, जिसकी हमें आवश्यकता होती है। यह एक सरल उदाहरण के साथ यह सब परीक्षण करने का समय है। ऐसा करने के लिए, समाधान में दूसरी परियोजना खोलें, C # में लिखा गया है, App.cs फ़ाइल खोलें और अगले टुकड़े को ठीक करें

 LargeMessageQueue queue = new LargeMessageQueue(queueFormatName);  LargeMessageQueue queue = new LargeMessageQueue(queueFormatName, 3145728); 

अब हम प्रोजेक्ट की पूरी असेंबली कर रहे हैं, सबसे पहले बिल्ड क्लीन करना सबसे अच्छा है।
यह वह जगह है जहां विकास समाप्त होता है। परीक्षण के लिए, हम एक सरल BizTalk एप्लिकेशन बनाएंगे जो कतार से एक संदेश लेगा और इसे C: \ Demo फ़ोल्डर में डाल देगा।

1. नाम के साथ स्थानीय कंप्यूटर पर एक निजी कतार बनाएं। बनाते समय, आपको एक पैरामीटर का चयन करना होगा जो लेनदेन कतार द्वारा समर्थन को इंगित करता है। जिस उपयोगकर्ता से आपका BizTalk सर्वर चल रहा है, उसे इस कतार से संदेश प्राप्त करने के अधिकारों की जाँच करना सुनिश्चित करें।
2. फ़ोल्डर C: \ Demo बनाएँ। फिर, उस उपयोगकर्ता के लिए फ़ोल्डर में लिखने के अधिकारों की जांच करना सुनिश्चित करें जहां से आपका BizTalk सर्वर चल रहा है
3. 3. बिज़टालक प्रशासन कंसोल खोलें और एक नया एप्लिकेशन बनाएं, इसे MSMQBiztalkTest कहें। इस एप्लिकेशन में, स्टेटिक वन-वे सेंड पोर्ट का सेंड पोर्ट बनाएं और इसे मायसेन्डपॉर्ट नाम दें। हम परिवहन प्रकार - फ़ाइल का चयन करते हैं और तदनुसार इसे कॉन्फ़िगर करते हैं ताकि यह C: \ डेमो फ़ोल्डर में हमारे संदेशों को स्टैक्ड करें जो हमने पहले बनाया था। हमने निम्नलिखित पोर्ट BTS.ReceivePortName == MyReceivePort के साथ इस पोर्ट पर फ़िल्टर सेट किया है
4. एक-तरफ़ा प्राप्त करने वाले पोर्ट प्रकार का एक नया प्राप्तकर्ता पोर्ट बनाएं और इसे MyReceivePort नाम दें। इस पोर्ट के लिए, MSMQReceiveLocation नामक वन-वे रिसीव स्थान प्रकार का एक नया प्राप्तकर्ता स्थान बनाएं। हम MSMQ के बराबर परिवहन प्रकार का चयन करते हैं और इसे हमारी कतार से संदेश प्राप्त करने के लिए सेट करते हैं। ऐसा करने के लिए, कतार को स्थानीयहोस्ट \ प्राइवेट $ \ परीक्षण में सेट करें और ट्रान्क्शनल टू ट्रू सेट करें।
5. इस परीक्षण पर BizTalk एप्लिकेशन बनाया गया है, आपको इसे शुरू करने और Biztalk सेवा को पुनरारंभ करने की आवश्यकता है।

कतार में एक संदेश भेजने के लिए, हम उस एप्लिकेशन का उपयोग करते हैं जिसे हमने VisualStudio 2010 में पहले बनाया था। यह कमांड लाइन से काम करता है और तदनुसार दो मापदंडों, कतार पैरामीटर और भेजने के लिए फ़ाइल का नाम लेता है।
SendLargeMessage.exe DIRECT = OS: localhost \ Private $ \ Test "C: \ TestData \ LargeFile.xml"
फ़ाइल के आकार के आधार पर, आप इसे कुछ ही सेकंड में C: \ Demo निर्देशिका में देख सकते हैं और इसे धीरे-धीरे विकसित होते हुए देख सकते हैं।
वह सब है। यदि किसी के पास कोई प्रश्न या सुझाव है, तो मुझे टिप्पणियों में सब कुछ जवाब देने में खुशी होगी।
सूत्रों का कहना है:
MSMQ को बड़ा संदेश