RabbitMQ - SQL सर्वर

एक या दो हफ्ते पहले, मैंने RabbitMQ Users फोरम पर एक संदेश देखा कि SQL Server से संदेश भेजने के लिए कैसे RabbitMQ स्थापित किया जाए। चूंकि हम डेरिवको के साथ मिलकर काम करते हैं, इसलिए मैंने वहां कुछ सुझाव छोड़ दिए, और यह भी कहा कि मैं यह कैसे करना है के बारे में एक ब्लॉग लिख रहा हूं। मेरे संदेश का एक हिस्सा पूरी तरह से सच नहीं था - कम से कम उस क्षण तक (क्षमा करें, भाई, वह बहुत व्यस्त था)।

बहुत बढ़िया बात है, यह आपका SQL सर्वर है । डेटाबेस में जानकारी डालना बहुत आसान है। क्वेरी का उपयोग करके डेटाबेस से डेटा पुनर्प्राप्त करना उतना ही आसान है। लेकिन अभी अद्यतन या चिपकाया गया डेटा प्राप्त करना थोड़ा अधिक कठिन है। वास्तविक समय की घटनाओं के बारे में सोचो; खरीदारी की जाती है - जैसे ही ऐसा हुआ किसी को इस बारे में सूचित किया जाना चाहिए। शायद कोई कहेगा कि इस तरह के डेटा को डेटाबेस से पॉप नहीं किया जाना चाहिए, लेकिन कहीं और से। बेशक, यह मामला है, लेकिन अक्सर हमारे पास कोई विकल्प नहीं है।

हमारे पास एक कार्य था: आगे की प्रक्रिया के लिए डेटाबेस से घटनाओं को भेजें, और सवाल था - यह कैसे करना है?

SQL सर्वर और बाहरी संचार

SQL सर्वर के अस्तित्व के दौरान, डेटाबेस के बाहर संचार को व्यवस्थित करने के लिए कई प्रयास किए गए हैं; SQL सर्वर सूचना सेवा (NS), जो SQL Server 2000 में दिखाई दी, और बाद में, SQL Server 2005 में, SQL सर्वर सेवा ब्रोकर (SSB) दिखाई दी। मैंने उन्हें बॉब बॉशेमेन और डैन सुलिवन के साथ डेवलपर्स के लिए एसक्यूएल सर्वर 2005 में अपनी पुस्तक ए फर्स्ट लुक में वर्णित किया। NS SQL Server 2000 में दिखाई दिया, जैसा कि मैंने कहा था, और SQL Server 2005 के बीटा संस्करण में पुन: डिज़ाइन किया गया था। हालाँकि, NS को SQL Server 2005 के रेडी-फॉर-सेल (RTM) संस्करण से पूरी तरह से बाहर रखा गया था।

नोट: यदि आप पुस्तक पढ़ते हैं, तो आपको वहाँ कई सुविधाएँ मिलेंगी जो RTM संस्करण में नहीं थीं।

SSB बच गया, और Microsoft ने अपने SQL Server 2008 फ़ीचर पैक में सर्विस ब्रोकर एक्सटर्नल एक्टीवेटर (EA) पेश किया। यह एसएसबी के माध्यम से स्थानीय डेटाबेस के बाहर बातचीत करना संभव बनाता है। सैद्धांतिक रूप से, यह अच्छा लगता है, लेकिन व्यवहार में - यह बोझिल और भ्रमित है। हमने कुछ परीक्षण किए और जल्दी से महसूस किया कि यह वह नहीं कर रहा था जिसकी हमें आवश्यकता थी। इसके अतिरिक्त, SSB ने हमें वह प्रदर्शन नहीं दिया जिसकी आवश्यकता थी, इसलिए हमें कुछ और आविष्कार करना था।

SQLCLR

परिणाम के रूप में हम SQLCLR तकनीक पर आधारित थे। SQLCLR एक .NET प्लेटफ़ॉर्म है जो SQL Server कोर में बनाया गया है और इसका उपयोग कर्नेल के अंदर .NET कोड को निष्पादित करने के लिए किया जा सकता है। चूंकि हम .NET कोड निष्पादित करते हैं, इसलिए हम लगभग सब कुछ नियमित .NET एप्लिकेशन के रूप में करने में सक्षम हैं।

नोट: मैंने ऊपर "लगभग" लिखा है, क्योंकि वास्तव में कुछ सीमाएं हैं। इस संदर्भ में, इन प्रतिबंधों का लगभग कोई प्रभाव नहीं पड़ता है कि हम क्या करने जा रहे हैं।

SQLCLR के संचालन का सिद्धांत इस प्रकार है: कोड एक dll लाइब्रेरी में संकलित किया गया है, और फिर यह लाइब्रेरी SQL सर्वर टूल्स का उपयोग करके पंजीकृत है:

विधानसभा का निर्माण

CREATE ASSEMBLY [RabbitMQ.SqlServer] AUTHORIZATION rmq FROM 'F:\some_path\RabbitMQSqlClr4.dll' WITH PERMISSION_SET = UNSAFE; GO 

कोड स्निपेट 1: एब्सोल्यूट पाथ के साथ असेंबली बनाना

कोड निम्नलिखित क्रियाएं करता है:

• CREATE ASSEMBLY - दिए गए नाम के साथ एक विधानसभा बनाता है (कोई फर्क नहीं पड़ता कि यह क्या होना चाहिए)।
• AUTHORIZATION - विधानसभा के मालिक को इंगित करता है। इस मामले में, rmq एक पूर्वनिर्धारित SQL सर्वर भूमिका है।
• FROM - यह निर्धारित करता है कि मूल विधानसभा कहाँ स्थित है। FROM , आप बाइनरी या UNC फॉर्मेट में पथ भी निर्दिष्ट कर सकते हैं। इस परियोजना के लिए अधिष्ठापन फाइलें एक बाइनरी प्रतिनिधित्व का उपयोग करती हैं।
• WITH PERMISSION_SET - अनुमतियाँ सेट करता है। UNSAFE कम कठोर और इस मामले में आवश्यक है।

नोट: AUTHORIZATION क्लॉज में इस्तेमाल की गई भूमिका या लॉगिन की परवाह किए बिना, अपडोमैन क्लास को उसी नाम से बनाया जाना चाहिए, जब असेंबली में लोड हो रहा हो। विधानसभाओं के विभिन्न नामों के साथ विधानसभाओं को अलग करने की सिफारिश की जाती है ताकि जब एक विधानसभा विफल हो जाए, तो बाकी न गिरे। हालाँकि, यदि असेंबली एक-दूसरे पर निर्भर हैं, तो उन्हें अलग-अलग वर्गों में विभाजित नहीं किया जा सकता है।

जब असेंबली बनाई जाती है, हम इसमें .NET विधियों के रैपर बनाते हैं:

 CREATE PROCEDURE rmq.pr_clr_PostRabbitMsg @EndpointID int, @Message nvarchar(max) AS EXTERNAL NAME [RabbitMQ.SqlServer].[RabbitMQSqlClr.RabbitMQSqlServer].[pr_clr_PostRabbitMsg]; GO 

कोड स्निपेट 2: .NET विधि आवरण

कोड निम्नलिखित क्रियाएं करता है:

• rmq.pr_clr_PostRabbitMsg नाम की एक T-SQL संग्रहीत कार्यविधि बनाता है जो दो पैरामीटर लेता है; @EndpointID और @Message ।
• प्रक्रिया के शरीर के बजाय, एक बाहरी स्रोत का उपयोग किया जाता है, जिसमें निम्न शामिल हैं:
  
  • RabbitMQ.SqlServer नाम का एक असेंबली, यानी कुल मिलाकर जो हमने कोड स्निपेट 1 में बनाया है।
  • पूर्ण प्रकार (नाम स्थान और वर्ग): RabbitMQSqlClr.RabbitMQSqlServer
  • उपरोक्त नामस्थान और वर्ग की विधि है: pr_clr_PostRabbitMsg ।

जब rmq.pr_clr_PostRabbitMsg किया जाता है, तो pr_clr_PostRabbitMsg विधि को बुलाया जाएगा।

नोट: एक प्रक्रिया बनाते समय, विधानसभा का नाम टाइप और विधि के पूर्ण नाम के विपरीत, संवेदनशील नहीं होता है। यह आवश्यक नहीं है कि बनाई जा रही प्रक्रिया का नाम विधि के नाम से मेल खाता हो। हालांकि, मापदंडों के लिए अंतिम डेटा प्रकार मेल खाना चाहिए।

जैसा कि मैंने पहले कहा, हम एसक्यूएल सर्वर के बाहर डेटा भेजने के लिए की जरूरत है, तो हम SQLCLR और प्रयोग Derivco करने के लिए है RabbitMQ (RMQ)।

RabbitMQ

RMQ एक ओपन सोर्स मैसेज ब्रोकर है जो एडवांस्ड मैसेज क्यूइंग प्रोटोकॉल (AMQP) को लागू करता है और एर्लांग में लिखा जाता है।

क्योंकि RMQ एक मैसेज ब्रोकर है, इससे जुड़ने के लिए AMQP क्लाइंट लाइब्रेरी की आवश्यकता होती है। एप्लिकेशन क्लाइंट पुस्तकालयों को संदर्भित करता है और, उनकी मदद से, एक कनेक्शन खोलता है और संदेश भेजता है - उदाहरण के लिए, SQL सर्वर के लिए ADO.NET के माध्यम से एक कॉल है। लेकिन ADO.NET के विपरीत, जहां, सबसे अधिक संभावना है, कनेक्शन हर बार डेटाबेस तक पहुंचने के बाद खुलता है, यहां कनेक्शन आवेदन की पूरी अवधि के लिए खुला रहता है।

इस प्रकार, RabbitMQ के साथ डेटाबेस से बातचीत करने में सक्षम होने के लिए, हमें RabbitMQ के लिए एप्लिकेशन और .NET क्लाइंट लाइब्रेरी की आवश्यकता है।

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

RabbitMQ.SqlServer

RabbitMQ.SqlServer एक असेंबली है जो RabbitMQ के लिए .NET क्लाइंट लाइब्रेरी का उपयोग करता है और डेटाबेस से एक या अधिक RabbitMQ समापन बिंदु (VHosts और एक्सचेंजर्स) को संदेश भेजने की क्षमता प्रदान करता है। कोड को GitHub पर मेरे रिपॉजिटरी RabbitMQ-SqlServer से डाउनलोड / कांटा किया जा सकता है। इसमें असेंबली सोर्स और इंस्टॉलेशन फाइल्स हैं (यानी आपको उन्हें खुद कंपाइल नहीं करना है)।

नोट: यह दिखाने के लिए कि SQL सर्वर RabbitMQ के साथ कैसे इंटरैक्ट कर सकता है, यह केवल एक उदाहरण है। यह एक तैयार उत्पाद या इसका हिस्सा भी नहीं है। यदि यह कोड आपके मस्तिष्क को तोड़ता है - मुझे दोष न दें, क्योंकि यह सिर्फ एक उदाहरण है।

कार्यक्षमता

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

संबंध

 internal bool InternalConnect() { try { connFactory = new ConnectionFactory(); connFactory.Uri = connString; connFactory.AutomaticRecoveryEnabled = true; connFactory.TopologyRecoveryEnabled = true; RabbitConn = connFactory.CreateConnection(); for (int x = 0; x < channels; x++) { var ch = RabbitConn.CreateModel(); rabbitChannels.Push(ch); } return true; } catch(Exception ex) { return false; } } 

कोड स्निपेट 3: समापन बिंदु से कनेक्ट करें

उसी समय, समापन बिंदु से कनेक्शन का हिस्सा भी कनेक्शन पर IModels बनाता है, और उन्हें (कतार में जोड़कर) संदेश भेजते समय उपयोग किया जाता है:

संदेश भेजना

 internal bool Post(string exchange, byte[] msg, string topic) { IModel value = null; int channelTryCount = 0; try { while ((!rabbitChannels.TryPop(out value)) && channelTryCount < 100) { channelTryCount += 1; Thread.Sleep(50); } if (channelTryCount == 100) { var errMsg = $"Channel pool blocked when trying to post message to Exchange: {exchange}."; throw new ApplicationException(errMsg); } value.BasicPublish(exchange, topic, false, null, msg); rabbitChannels.Push(value); return true; } catch (Exception ex) { if (value != null) { _rabbitChannels.Push(value); } throw; } } 

Post विधि को pr_clr_PostRabbitMsg(int endPointId, string msgToPost) विधि pr_clr_PostRabbitMsg(int endPointId, string msgToPost) किया जाता है, जिसे एक प्रक्रिया के रूप में प्रस्तुत किया गया था, जो कोड 2 में pr_clr_PostRabbitMsg(int endPointId, string msgToPost) CREATE PROCEDURE खंड का उपयोग कर रहा था।

पोस्ट कॉलिंग विधि

 public static void pr_clr_PostRabbitMsg(int endPointId, string msgToPost) { try { if(endPointId == 0) { throw new ApplicationException("EndpointId cannot be 0"); } if (!isInitialised) { pr_clr_InitialiseRabbitMq(); } var msg = Encoding.UTF8.GetBytes(msgToPost); if (endPointId == -1) { foreach (var rep in remoteEndpoints) { var exch = rep.Value.Exchange; var topic = rep.Value.RoutingKey; foreach (var pub in rabbitPublishers.Values) { pub.Post(exch, msg, topic); } } } else { RabbitPublisher pub; if (rabbitPublishers.TryGetValue(endPointId, out pub)) { pub.Post(remoteEndpoints[endPointId].Exchange, msg, remoteEndpoints[endPointId].RoutingKey); } else { throw new ApplicationException($"EndpointId: {endPointId}, does not exist"); } } } catch { throw; } } 

कोड स्निपेट 5: प्रक्रिया के रूप में एक विधि का प्रतिनिधित्व करना

जब विधि को निष्पादित किया जाता है, तो यह माना जाता है कि कॉल करने वाला अंतिम बिंदु के पहचानकर्ता को भेजता है जिसमें संदेश प्रसारित किया जाना चाहिए, और वास्तव में, संदेश स्वयं। यदि मान -1 को समापन बिंदु के पहचानकर्ता के रूप में पारित किया जाता है, तो हम सभी बिंदुओं पर पुनरावृति करते हैं और उनमें से प्रत्येक को एक संदेश भेजते हैं। एक संदेश एक लाइन है, जिसमें से हम प्रयोग कर बाइट्स मिल के रूप में आता है Encoding.UTF8.GetBytes । एक उत्पादन वातावरण में, Encoding.UTF8.GetBytes कॉल को क्रमांकन के साथ प्रतिस्थापित किया जाना चाहिए।

स्थापना

उदाहरण को स्थापित करने और चलाने के लिए, आपको src\SQL फ़ोल्डर में सभी फ़ाइलों की आवश्यकता है। स्थापित करने के लिए, इन चरणों का पालन करें:

• स्क्रिप्ट को चलाएँ 01.create_database_and_role.sql । वह बनाएंगे:
  
  • RabbitMQTest परीक्षण डेटाबेस जहाँ असेंबली बनाई जाएगी।
  • rmq भूमिका को विधानसभा के मालिक के रूप में सौंपा जाएगा
  • योजना, जिसे rmq भी कहा rmq । इस आरेख में, विभिन्न डेटाबेस ऑब्जेक्ट बनाए जाते हैं।
    
  
  
• 02.create_database_objects.sql फ़ाइल चलाएँ। वह बनाएंगे:
  
  
  • rmq.tb_RabbitSetting तालिका, जो कनेक्शन स्ट्रिंग को स्थानीय डेटाबेस में संग्रहीत करेगी।
  • rmq.tb_RabbitEndpoint टेबल, जिसमें एक या एक से अधिक RabbitMQ समापन बिंदु संग्रहीत होंगे।
  
  
• 03.create_localhost_connstring.sql फ़ाइल में 03.create_localhost_connstring.sql चरण 1 में निर्मित RabbitMQTest डेटाबेस के लिए सही कनेक्शन स्ट्रिंग के लिए @connString चर का मान बदलें और स्क्रिप्ट चलाएँ।
  

जारी रखने से पहले, आपके पास RabbitMQ ब्रोकर का एक इंस्टेंस होना चाहिए और VHost (डिफ़ॉल्ट रूप से, VHost को / के रूप में दर्शाया गया है)। एक नियम के रूप में, हमारे पास कई VHost हैं, बस अलगाव के लिए। इस मेजबान को भी एक एक्सचेंजर की आवश्यकता होती है, उदाहरण में हम amq.topic उपयोग amq.topic । जब आपका RabbitMQ ब्रोकर तैयार हो जाता है, तो rmq.pr_UpsertRabbitEndpoint प्रक्रिया rmq.pr_UpsertRabbitEndpoint संपादित करें, जो 04.upsert_rabbit_endpoint.sql फ़ाइल में स्थित है:

समापन बिंदु RabbitMQ

 EXEC rmq.pr_UpsertRabbitEndpoint @Alias = 'rabbitEp1', @ServerName = 'RabbitServer', @Port = 5672, @VHost = 'testHost', @LoginName = 'rabbitAdmin', @LoginPassword = 'some_secret_password', @Exchange = 'amq.topic', @RoutingKey = '#', @ConnectionChannels = 5, @IsEnabled = 1 

कोड स्निपेट 6: रैबिटक्यू में एक समापन बिंदु बनाना

इस बिंदु पर, यह असेंबलियों को तैनात करने का समय है। SQL सर्वर 2014 (2005, 2008, 2008R2, 2012) से पहले और 2014 और उसके बाद के लिए SQL सर्वर के संस्करणों के लिए परिनियोजन विकल्पों में अंतर हैं। अंतर सीएलआर के समर्थित संस्करण में निहित है। SQL सर्वर 2014 से पहले, .NET प्लेटफ़ॉर्म CLR संस्करण 2 में चल रहा था, और SQL सर्वर 2014 और इसके बाद के संस्करण में, संस्करण 4 का उपयोग किया गया था।

SQL सर्वर 2005 - 2012

चलो SQL सर्वर के संस्करणों से शुरू करते हैं जो CLR 2 पर चलते हैं, क्योंकि उनकी अपनी विशेषताएं हैं। हमें निर्मित असेंबली को परिनियोजित करने की आवश्यकता है, और उसी समय RabbitMQ क्लाइंट .NET लाइब्रेरी ( RabbitMQ.Client ) को तैनात करें। हमारी विधानसभा से हम रैबिटएमक्यू क्लाइंट लाइब्रेरी का उल्लेख करेंगे। क्योंकि चूँकि हमने CLR 2, हमारी असेंबली और RabbitMQ.Client का उपयोग करने की योजना बनाई है। इसे .NET 3.5 पर आधारित संकलित किया जाना चाहिए। समस्याएं हैं।

RabbitMQ.Client लाइब्रेरी के सभी नवीनतम संस्करण CLR 4 पर्यावरण के लिए संकलित किए गए हैं, इसलिए वे हमारे असेंबली में उपयोग नहीं किए जा सकते हैं। CLR 2 के लिए क्लाइंट पुस्तकालयों का नवीनतम संस्करण .NET 3.4.3 पर संकलित किया गया है। लेकिन फिर भी यदि हम इस विधानसभा को तैनात करने का प्रयास करते हैं, तो हमें एक त्रुटि संदेश मिलता है:


चित्र 1: मिसिंग सिस्टम। ServiceModel असेंबली

RabbitMQ.Client का यह संस्करण SQL सर्वर CLR का हिस्सा नहीं होने वाली असेंबली को संदर्भित करता है। यह एक WCF असेंबली है, और यह SQLCLR की उन सीमाओं में से एक है, जिनका मैंने ऊपर उल्लेख किया है: यह विशेष असेंबली उन प्रकार के कार्यों के लिए होती है, जिन्हें SQL Server में निष्पादित करने की अनुमति नहीं है। RabbitMQ.Client हाल के संस्करणों में ये निर्भरताएं नहीं हैं, इसलिए उन्हें CLR की कष्टप्रद आवश्यकताओं को छोड़कर किसी भी समस्या के बिना उपयोग किया जा सकता है। मुझे क्या करना चाहिए?

जैसा कि आप जानते हैं, RabbitMQ एक खुला स्रोत है, लेकिन हम डेवलपर्स हैं, है ना? ;) तो चलो recompile! RabbitMQ.Client के नवीनतम रिलीज़ (यानी संस्करण <3.5.0) से पहले के संस्करण में RabbitMQ.Client मैंने System.ServiceModel के लिंक हटा दिए और पुन: संकलित कर लिया। मुझे System.ServiceModel कार्यक्षमता का उपयोग करके कोड की कुछ पंक्तियों को बदलना था, लेकिन ये मामूली परिवर्तन थे।

इस उदाहरण में, मैंने क्लाइंट संस्करण 3.4.3 का उपयोग नहीं किया, लेकिन मैंने स्थिर रिलीज 3.6.6 लिया और .NET 3.5 (सीएलआर 2) का उपयोग करके पुन: संकलित किया । इसने लगभग काम किया :), सिवाय इसके कि बाद में RabbitMQ.Client Task 'का विमोचन हुआ और जो मूल रूप से .NET 3.5 का हिस्सा नहीं हैं।

सौभाग्य से, .NET 3.5 के लिए System.Threading.dll का एक संस्करण है जिसमें Task शामिल है। मैंने इसे डाउनलोड किया, लिंक सेट किया और सब कुछ चला गया! यहां मुख्य चाल यह है कि System.Threading.dll को विधानसभा के साथ स्थापित किया जाना चाहिए।

नोट: स्रोत RabbitMQ.Client , जिसमें से मैं .NET 3.5 के संस्करण के लिए एकत्र हुए, वहाँ GitHub पर मेरी खजाने में है RabbitMQ 3.6.6 क्लाइंट .NET 3.5 । .NET 3.5 के लिए System.Threading.dll के साथ dll बाइनरी भी रिपॉजिटरी (RabbitMQ-SqlServer) के lib\NET3.5 में निहित है।

आवश्यक असेंबली स्थापित करने के लिए ( System.Threading , RabbitMQ.Client और RabbitMQ.SqlServer ) निम्न क्रम में src\sql निर्देशिका से संस्थापन स्क्रिप्ट चलाएँ:

1. 05.51.System.Threading.sql2k5-12.sql - System.Threading
2. 05.52.RabbitMQ.Client.sql2k5-12.sql - 05.52.RabbitMQ.Client.sql2k5-12.sql
3. 05.53.RabbitMQ.SqlServer.sql2k5-12.sql - RabbitMQ.SqlServer

SQL सर्वर 2014+

SQL सर्वर 2014 और बाद में, असेंबली .NET 4.XX के तहत संकलित करता है (मेरा उदाहरण 4.5.2 पर है), और आप RabbitMQ.Client किसी भी नवीनतम संस्करण को संदर्भित कर सकते हैं, जिसे NuGet का उपयोग करके प्राप्त किया जा सकता है। मेरे उदाहरण में, मैं 4.1.1 का उपयोग कर रहा हूं। RabbitMQ.Client , जो रिपॉजिटरी (RabbitMQ-SqlServer) के lib\NET4 है ।

निम्नलिखित क्रम में src\sql निर्देशिका से स्क्रिप्ट चलाने के लिए:

1. 05.141.RabbitMQ.Client.sql2k14+.sql - RabbitMQ.Client
2. 05.142.RabbitMQ.SqlServer.sql2k14+.sql - 05.142.RabbitMQ.SqlServer.sql2k14+.sql

एसक्यूएल विधि आवरण

हमारी असेंबली (3.5 या 4) से उपयोग की जाने वाली प्रक्रियाएँ बनाने के लिए, स्क्रिप्ट 06.create_sqlclr_procedures.sql । वह तीन .NET विधियों के लिए टी-एसक्यूएल प्रक्रियाएँ बनाएगा:

• rmq.pr_clr_InitialiseRabbitMq कॉल pr_clr_InitialiseRabbitMq । RabbitMQ.SqlServer असेंबली को लोड और प्रारंभ करने के लिए उपयोग किया जाता है।
• rmq.pr_clr_ReloadRabbitEndpoints का कारण बनता है pr_clr_ReloadRabbitEndpoints । विभिन्न RabbitMQ समापन बिंदु लोड करता है।
• rmq.pr_clr_PostRabbitMsg कहता है। RabbitMQ को संदेश भेजने के लिए उपयोग किया जाता है।

स्क्रिप्ट एक साधारण T-SQL प्रक्रिया भी बनाती है - rmq.pr_PostRabbitMsg , जो rmq.pr_clr_PostRabbitMsg पर लागू होती है। यह एक आवरण प्रक्रिया है जो जानती है कि डेटा के साथ क्या करना है, अपवादों को संभालना आदि। उत्पादन परिवेश में, हमारे पास कई समान प्रक्रियाएं हैं जो विभिन्न प्रकार के संदेशों को संसाधित करती हैं। इसके बारे में नीचे पढ़ें।

के उपयोग

उपरोक्त सभी से, यह स्पष्ट है कि RabbitMQ को संदेश भेजने के लिए हम rmq.pr_PostRabbitMsg या rmq.pr_clr_PostRabbitMsg कॉल rmq.pr_clr_PostRabbitMsg , मापदंडों में समापन बिंदु के पहचानकर्ता और संदेश को एक स्ट्रिंग के रूप में पास करते हैं। यह सब, ज़ाहिर है, शांत है, लेकिन मैं यह देखना चाहूंगा कि यह वास्तविकता में कैसे काम करेगा।

हम उत्पादन वातावरण में जो करते हैं वह यह है कि संग्रहीत कार्यविधियों में जो डेटा को RabbitMQ को भेजा जाना चाहिए, हम भेजे जाने वाले डेटा को इकट्ठा करते हैं और कनेक्शन ब्लॉक में हम rmq.pr_PostRabbitMsg जैसी प्रक्रिया rmq.pr_PostRabbitMsg । निम्नलिखित इस तरह की प्रक्रिया का एक बहुत ही सरल उदाहरण है:

डाटा प्रोसेसिंग प्रक्रिया

 ALTER PROCEDURE dbo.pr_SomeProcessingStuff @id int AS BEGIN SET NOCOUNT ON; BEGIN TRY --     DECLARE @endPointId int; --    DECLARE @msg nvarchar(max) = '{' --        SET @msg = @msg + '"Id":' + CAST(@id AS varchar(10)) + ',' --  -  SET @msg = @msg + '"FName":"Hello",'; SET @msg = @msg + '"LName":"World"'; SET @msg = @msg + '}'; -- -  --     -,  -  SELECT @endPointId = 1; --    --     EXEC rmq.pr_PostRabbitMsg @Message = @msg, @EndpointID = @endPointId; END TRY BEGIN CATCH DECLARE @errMsg nvarchar(max); DECLARE @errLine int; SELECT @errMsg = ERROR_MESSAGE(), @errLine = ERROR_LINE(); RAISERROR('Error: %s at line: %d', 16, -1, @errMsg, @errLine); END CATCH END 

कोड टुकड़ा 7 में, हम देखते हैं कि कैसे आवश्यक डेटा को कैप्चर किया जाता है और प्रक्रिया में संसाधित किया जाता है और प्रसंस्करण के बाद भेजा जाता है। इस प्रक्रिया का उपयोग करने के लिए, src\SQL निर्देशिका से 07.create_processing_procedure.sql स्क्रिप्ट चलाएँ।

चलो इसे सब चलाते हैं

इस बिंदु पर, आपको कुछ संदेश भेजने के लिए तैयार रहना चाहिए। परीक्षण करने से पहले, सुनिश्चित करें कि आपके पास rmq.tb_RabbitEndpoint में समापन बिंदु एक्सचेंजर से जुड़े RabbitMQ में rmq.tb_RabbitEndpoint ।

तो, आपको निम्नलिखित करने की आवश्यकता है:
99.test_send_message.sql फ़ाइल खोलें।
का पालन करें

 EXEC rmq.pr_clr_InitialiseRabbitMq; 

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

का पालन करें

 EXEC dbo.pr_SomeProcessingStuff @id = 101 

(आप अपनी पसंद के किसी अन्य पहचानकर्ता का उपयोग कर सकते हैं)।

यदि सब कुछ त्रुटियों के बिना काम करता है, तो एक संदेश RabbitMQ कतार में दिखाई देना चाहिए! इसलिए आपने RabCLMQ को संदेश भेजने के लिए SQLCLR का उपयोग किया।

Kongratuleyshens!