RabbitMQ में निगरानी संदेश

निर्माता, एक्सचेंज, कतार और उपभोक्ता तत्वों से मिलकर क्लासिक RabbitMQ संदेश पाइपलाइन डिजाइन योजना पर विचार करें।



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

सबसे पहले, हम एक प्रदर्शन स्टैंड का आयोजन करेंगे, इसके लिए हम कन्वेयर के संचालन में निम्नलिखित बदलाव करेंगे:



प्रारंभ में, निम्न कॉन्फ़िगरेशन एक्सचेंज (फ़ॉस्ट) के लिए निर्धारित की गई थी, जो संशोधन के दौरान विचार किए गए उदाहरण में नहीं बदलती है:



एक महत्वपूर्ण सेटिंग प्रकार का फेनौट है - जो आपको दो पीयर-टू-पीयर कतार बनाने और संपूर्ण संदेश प्रवाह को नई सांख्यिकी कतार में कॉपी करने की अनुमति देता है:





लॉग्स कतार में मुख्य प्रक्रिया के साथ किसी भी हस्तक्षेप के बिना। संदेश प्रवाह को संसाधित करना शुरू करते हैं। सबसे पहले, हम सांख्यिकीय जानकारी संग्रहीत करने के लिए MS SQL सर्वर पर एक तालिका बनाते हैं। आप किसी भी अन्य दृष्टिकोण का उपयोग कर सकते हैं, उदाहरण के लिए, संदेश को xml प्रारूप या किसी अन्य तरीके से फ़ाइल में सहेजें, इस उदाहरण में, SQL सर्वर को अतिरिक्त प्रोग्रामिंग से बचने के लिए चुना गया है

create table RabbitMsg( id int PRIMARY KEY IDENTITY(1000,1), [Message] nvarchar(1000) DEFAULT '', RegDate datetime default GETDATE()) 

जैसा कि आप SQL क्वेरी से देख सकते हैं, यह एक तालिका है जिसमें एक रिकॉर्ड संख्या, कुछ पाठ और तारीख दर्ज की गई थी।

आइए एक ग्राहक बनाएं जो सांख्यिकी कतार में RabbitMQ से संपर्क करेगा, प्राप्त डेटा एकत्र करेगा और इसे RabbitMsg तालिका में स्थानांतरित करेगा।

 using System; using RabbitMQ.Client; using RabbitMQ.Client.Events; using System.Text; using System.Data.SqlClient; namespace Getter { class Program { static void Main(string[] args) { var factory = new ConnectionFactory() { HostName = "192.168.1.241", Port = 30672, UserName = "robotics01", Password = "" }; using (var connection = factory.CreateConnection()) using (var channel = connection.CreateModel()) { channel.ExchangeDeclare(exchange: "faust", type: "fanout", durable: true); var queueName = "Statistics"; channel.QueueBind(queue: queueName, exchange: "faust", routingKey: ""); Console.WriteLine(" [*] Waiting for logs."); var consumer = new EventingBasicConsumer(channel); consumer.Received += (model, ea) => { var body = ea.Body; var message = Encoding.UTF8.GetString(body); Console.WriteLine(" [x] {0}", message); SqlConnection sqlconnection = new SqlConnection("Server=tcp:fastreportsql,1433;Initial Catalog=FastReportSQL;Persist Security Info=False;User ID=ufocombat;Password=;MultipleActiveResultSets=False;Encrypt=True;TrustServerCertificate=False;Connection Timeout=30;"); sqlconnection.Open(); SqlCommand cmd = new SqlCommand($"INSERT INTO RabbitMsg(Message) VALUES (@msg)", sqlconnection); cmd.Parameters.AddWithValue("msg", message); cmd.ExecuteNonQuery(); sqlconnection.Close(); }; channel.BasicConsume(queue: queueName, autoAck: false, consumer: consumer); Console.WriteLine(" Press [enter] to exit."); Console.ReadLine(); } Console.WriteLine("Hello World!"); } } } 

आइए देखें कि यह वास्तविक समय में कैसे काम करता है।


इस बीच, एमएस SQL ​​सर्वर पर



सांख्यिकी कतार के आधार पर एक रिपोर्ट बनाएँ


यहाँ क्या हुआ:

निष्कर्ष

माना गया उदाहरण दिखाता है कि आंकड़े कैसे जल्दी से इकट्ठा किए जा सकते हैं और यहां तक ​​कि एक रिपोर्ट भी बनाई जा सकती है जिसे पीडीएफ में सहेजा जा सकता है और RabbitMQ पाइपलाइन और एक अतिरिक्त कतार के अनुसार मेल द्वारा भेजा जा सकता है। जब किसी भी प्रक्रिया के बारे में जानकारी एकत्र की जाती है और सर्वर साइड को विकसित किए बिना रिपोर्ट बनाई जाती है तो कार्यों के उदाहरणों के साथ आना आसान होता है। यह देखते हुए कि FastReports एक ओपन-सोर्स संस्करण प्रदान करता है, बिना किसी अतिरिक्त लागत के विकास लागत को कम करना संभव है। कन्वेयर खुद भी आसानी से मिलनसार है और अधिक जटिल कार्यों के लिए अनुकूलित किया जा सकता है।