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

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

छोटा सा परिचय

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

कठोर परिचालन स्थितियों को देखते हुए, प्रोटोकॉल को छोटा और हल्का बनाया जाता है। यह कम बिजली उपकरणों और सीमित बैटरी जीवन के लिए आदर्श है। इनमें अब सर्वव्यापी स्मार्टफोन शामिल हैं, और सेंसर और जुड़े उपकरणों की बढ़ती संख्या।

इस प्रकार, एमक्यूटीटी सीमित सीपीयू शक्ति और / या बैटरी जीवन के साथ उपकरणों के बीच डेटा स्ट्रीमिंग के लिए एक प्रोटोकॉल बन गया है, साथ ही महंगे या कम बैंडविड्थ, अप्रत्याशित स्थिरता या उच्च विलंबता वाले नेटवर्क के लिए। इसीलिए MQTT को IoT के लिए आदर्श वाहन के रूप में जाना जाता है। यह टीसीपी / आईपी प्रोटोकॉल पर बनाया गया है, लेकिन ब्लूटूथ, यूडीपी, ज़िगबी और टीसीपी / आईपी के अलावा अन्य IoT नेटवर्क के माध्यम से काम करने के लिए एक MQTT-SN शाखा है।

MQTT अपनी तरह का एकमात्र वास्तविक समय पब / उप संदेश प्रोटोकॉल नहीं है, लेकिन यह पहले से ही विभिन्न वातावरणों में व्यापक हो गया है जो मशीन-टू-मशीन संचार पर निर्भर करते हैं। उनके साथियों में वेब एप्लिकेशन मैसेजिंग प्रोटोकॉल , स्ट्रीमिंग टेक्स्ट-ओरिएंटेड मैसेजिंग प्रोटोकॉल और वैकल्पिक संदेश कतारबद्ध प्रोटोकॉल हैं ।

MQTT डेवलपर्स के लिए तार्किक विकल्प है जो विश्वसनीय कार्यक्षमता और उपकरणों के साथ व्यापक अनुकूलता और इंटरनेट से जुड़े एप्लिकेशन बनाना चाहते हैं, जिसमें ब्राउज़र, स्मार्टफ़ोन और IoT डिवाइस शामिल हैं।

कैसे MQTT काम करता है: मूल बातें

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



एमक्यूटीटी संचार चैनलों की पदानुक्रम बनाने का एक तरीका प्रदान करता है - पत्तियों के साथ एक तरह की शाखा। जब भी प्रकाशक के पास ग्राहकों को वितरित करने के लिए नया डेटा होता है, तो संदेश वितरण नियंत्रण नोट के साथ होता है। उच्च-स्तरीय ग्राहक प्रत्येक संदेश प्राप्त कर सकते हैं, जबकि निचले स्तर के ग्राहक केवल एक या दो मूल चैनल से संबंधित संदेश प्राप्त कर सकते हैं, पदानुक्रम के नीचे "शाखाएं"। यह दो बाइट्स से 256 मेगाबाइट तक के आकार की जानकारी के आदान-प्रदान की सुविधा प्रदान करता है।

MQTT ब्रोकर के माध्यम से कनेक्ट करने के लिए आप क्लाइंट को कैसे कॉन्फ़िगर कर सकते हैं इसका एक उदाहरण:

var options = { keepalive: 60, username: 'FIRST_HALF_OF_API_KEY', password: 'SECOND_HALF_OF_API_KEY', port: 8883 }; var client = mqtt.connect('mqtts:mqtt.ably.io', options); 

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

 var ably = new Ably.Realtime('REPLACE_WITH_YOUR_API_KEY'); var decoder = new TextDecoder(); var channel = ably.channels.get('input'); channel.subscribe(function(message) { var command = decoder.decode(message.data); }); 

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

यह उल्लेखनीय है कि MQTT स्पष्ट पाठ में सुरक्षा क्रेडेंशियल प्रसारित करता है, अन्यथा प्रमाणीकरण या सुरक्षा कार्यों का समर्थन नहीं किया जाता है। यह वह जगह है जहां एसएसएल फ्रेमवर्क खेल में आता है , संचारित जानकारी को इंटरसेप्ट होने या अन्यथा छेड़छाड़ से बचाने में मदद करता है।

इसके अतिरिक्त, MQTT में, आप टोकन पर Ably प्रमाणीकरण का उपयोग कर सकते हैं यदि आप अपनी API कुंजी को वास्तविक MQTT क्लाइंट पर बिल्कुल भी प्रकट नहीं करना चाहते हैं (SSL के बिना MQTT के मामले में, स्पष्ट पाठ में एपीआई कुंजियों के हस्तांतरण को रोकने के लिए टोकन की आवश्यकता होती है)। टोकन प्रमाणीकरण उदाहरण:

 var options = { keepalive: 60, username: INSERT_TOKEN_HERE, password: '', port: 8883 }; var client = mqtt.connect('mqtts:mqtt.ably.io', options); client.subscribe("[mqtt]tokenevents", { /* Create a new token called 'NEW_TOKEN' */ client.end(); options.username = NEW_TOKEN; client = mqtt.connect('mqtts:mqtt.ably.io', options); }); 

MQTT कार्यक्षमता: गहरा विसर्जन

IBM के अनुसार , MQTT के निम्नलिखित गुण हैं:

• संदेश सामग्री के लिए तटस्थ
  
• वितरित एक-से-कई संचार और डिस्कनेक्ट किए गए एप्लिकेशन के लिए आदर्श
  
• LWT फ़ंक्शन (अंतिम वसीयत और वसीयतनामा, "अंतिम वसीयत और वसीयतनामा) से लैस ग्राहक के असामान्य वियोग के दलों को सूचित करने के लिए
  
• बुनियादी संचार कार्यों के लिए टीसीपी / आईपी पर निर्भर करता है
  
• "कम से कम एक बार", "कम से कम एक बार" और "बिल्कुल एक बार" टेम्पलेट्स का उपयोग करके संदेश देने के लिए बनाया गया

MQTT सिस्टम का एक सदस्य प्रकाशक, उपभोक्ता या दोनों भूमिकाओं की भूमिका एक साथ ले सकता है।

MQTT की विशिष्ट विशेषताओं में से एक चैनलों की अपनी अनूठी समझ है: उनमें से प्रत्येक को फ़ाइल पथ के रूप में माना जाता है, उदाहरण के लिए:

 channel = "user/path/channel" 

चैनल सुनिश्चित करते हैं कि प्रत्येक ग्राहक को उसके लिए नियत संदेश प्राप्त हों। चैनलों को फ़ाइल पथ के रूप में मानकर, MQTT सभी प्रकार के उपयोगी संचार कार्य करता है, जिसमें संदेश को किस आधार पर - किस स्तर पर या किस शाखा में - ग्राहकों को फ़ाइल पथ की सदस्यता दी जाती है सहित शामिल हैं।

MQTT संदेश प्रारूप

प्रत्येक MQTT संदेश बनाने वाले दो घटकों को देखें:

• बाइट 1 : में संदेश का प्रकार (ग्राहक का कनेक्शन अनुरोध, सदस्यता की पुष्टि, पिंग अनुरोध, आदि), एक दोहराव ध्वज, संदेशों को बचाने के लिए निर्देश और सेवा की गुणवत्ता (क्यूओएस) के बारे में जानकारी शामिल है।
  
• बाइट 2 : शेष संदेश लंबाई के बारे में जानकारी है, जिसमें पेलोड और एक वैकल्पिक चर के हेडर में कोई डेटा शामिल है।

बाइट 1 में QoS ध्वज विशेष ध्यान देने योग्य है, क्योंकि यह चर कार्यक्षमता का समर्थन करता है जो MQTT का समर्थन करता है। QoS झंडे में संदेश के इरादे और तात्कालिकता के आधार पर निम्नलिखित मूल्य शामिल हैं:

• 0 = एक बार से अधिक नहीं: सर्वर ट्रिगर है और भूल जाता है। संदेश गुम या डुप्लिकेट हो सकते हैं।
  
• 1 = कम से कम एक बार: प्राप्तकर्ता डिलीवरी की पुष्टि करता है। संदेशों को डुप्लिकेट किया जा सकता है, लेकिन डिलीवरी की गारंटी है
  
• 2 = बिल्कुल एक बार: सर्वर डिलीवरी प्रदान करता है। संदेश बिना नुकसान या दोहराव के एक बार पहुंचते हैं

आइए आइए देखें कि IoT उपकरणों और अन्य अनुप्रयोगों में विभिन्न QoS स्तरों का उपयोग कैसे करें।

मैं MQTT का उपयोग कहां कर सकता हूं?

चूंकि IoT अनुप्रयोगों को अब बड़े पैमाने पर कार्यान्वित किया जा रहा है, MQTT एक खुले, सरल और स्केलेबल तरीके के रूप में वितरित कंप्यूटिंग और आईओटी कार्यक्षमता को व्यापक उपयोगकर्ता आधार के लिए तैनात करने के लिए आया है - दोनों उपभोक्ता और औद्योगिक बाजारों में।

जैसा कि ऊपर कहा गया है, MQTT बिजली की आपूर्ति और सीपीयू पर प्रतिबंध के साथ अविश्वसनीय नेटवर्क और उपकरणों के लिए बनाया गया एक हल्का संदेश प्रोटोकॉल है। हालांकि, इसका मतलब यह नहीं है कि संभावित पैकेट नुकसान के साथ कनेक्शन इसका एकमात्र आवेदन है। MQTT विभिन्न प्रकार की IoT अवसंरचना के लिए विभिन्न स्तरों की सेवा प्रदान करता है, जिसमें डेटा नमूनाकरण से लेकर औद्योगिक मशीनों का प्रबंधन शामिल है:

• पर्यावरण सेंसर डेटा : जैसा कि पहले ही उल्लेख किया गया है, MQTT "डिलीवरी से अधिक नहीं" संदेश वितरण मॉडल का समर्थन करता है। आंशिक कवरेज या उच्च विलंबता वाले नेटवर्कों में, इसका अर्थ है कि जानकारी गुम या दोहराई जा सकती है। उन क्षेत्रों में जहां दूरस्थ सेंसर निर्दिष्ट अंतराल पर डेटा रिकॉर्ड और संचारित करते हैं, यह कोई समस्या नहीं है, क्योंकि नियमित रूप से नए रीडिंग प्राप्त होते हैं। दूरस्थ वातावरण में सेंसर आमतौर पर कम-शक्ति वाले उपकरण होते हैं, जो अपेक्षाकृत कम डेटा ट्रांसफर प्राथमिकता के साथ IoT सेंसर के लिए आदर्श समाधान MQTT बनाते हैं।
  
• मशीन का प्रदर्शन डेटा : समस्याओं का तुरंत जवाब देने और डाउनटाइम को रोकने के लिए। उदाहरण के लिए, एक पवन ऊर्जा स्थापना को डेटा केंद्र तक इस जानकारी के पहुंचने से पहले ही स्थानीय टीमों को वर्तमान प्रदर्शन संकेतकों की गारंटी की आवश्यकता होती है। ऐसी स्थितियों में, संदेशों की डिलीवरी "कम से कम एक बार" यह सुनिश्चित करती है कि उपयुक्त विशेषज्ञों को तत्काल आवश्यक विशेषज्ञों द्वारा देखा जाए, भले ही वे डुप्लिकेट के रूप में पहुंचे। यह उच्च प्राथमिकता वाली मशीन संचार के लिए महत्वपूर्ण है।
  
• बिलिंग प्रणाली : और भी अधिक प्राथमिकता और सटीक संदेश हैं जिन्हें सही तरीके से संसाधित करने की आवश्यकता है। व्यावसायिक स्थितियों में, जहाँ अभिलेखों का दोहराव अस्वीकार्य है, जिसमें बिलिंग सिस्टम शामिल हैं, "ठीक एक बार" क्यूओएस ध्वज उपयोगी है। यह बिलिंग या बिलिंग सिस्टम में पैकेजों के दोहराव या नुकसान को समाप्त करता है, सहमति के अनुसार विसंगतियों और अनावश्यक विरोधाभासों की संख्या को कम करता है।

MQTT का उपयोग कब नहीं करना चाहिए?

डेवलपर्स के पास MQTT, HTTP, CoAP , WebSockets (यदि CPU / बैटरी अनुमति देता है) और अन्य सहित द्विदिश IoT संचार चैनलों को डिजाइन और तैनात करने के लिए प्रोटोकॉल का एक विस्तृत चयन है। क्या MQTT सबसे अच्छा विकल्प है, हार्डवेयर और अनुप्रयोग के कार्य पर निर्भर करता है।

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

MQTT को अक्सर HTTP के साथ-साथ संदर्भित किया जाता है, इसलिए Google ने एक अध्ययन किया, जो प्रतिक्रिया समय, ट्रैफ़िक वॉल्यूम और डेवलपर्स के लिए महत्वपूर्ण अन्य विशेषताओं से उनकी तुलना करता है। MQTT ने Google परीक्षणों में पहला स्थान प्राप्त किया, लेकिन केवल उन परिस्थितियों में जब कनेक्शन को कई पेलोड भेजने के लिए पुन: उपयोग किया जा सकता है ।

अपेक्षाकृत कम मात्रा में ट्रैफ़िक, कम बैटरी और मेमोरी आवश्यकताओं के कारण HTTP और MQTT IoT अनुप्रयोगों के लिए एक अच्छा विकल्प है।

सीओएपी एक और प्रोटोकॉल है जो अक्सर IoT सिस्टम को विकसित करने के लिए MQTT से तुलना किया जाता है। वे समान हैं, लेकिन ध्यान देने योग्य अंतर हैं। एमक्यूटीटी कई-से-कई प्रोटोकॉल है, जबकि सीओएपी मूल रूप से एक सर्वर और एक क्लाइंट के बीच संचार के लिए एक-से-एक प्रोटोकॉल है। उसी समय, CoAP मेटाडेटा, खोज और सामग्री बातचीत सुविधाएँ प्रदान करता है जो MQTT के पास नहीं है ।

ऐसे मामलों में जहां ग्राहकों को केवल डेटा प्राप्त करना चाहिए, सर्वर-भेजा इवेंट भी एक उपयुक्त विकल्प है।

MQTT को जल्दी कैसे सेट करें

GitHub पर MQTT रिपॉजिटरी में विभिन्न भाषाओं में खुले स्रोत MQTT पुस्तकालयों की एक विस्तृत सूची है । निम्नलिखित ओपन सोर्स MQTT ब्रोकर, जावास्क्रिप्ट लाइब्रेरी और .NET लाइब्रेरी का उपयोग करते हुए अनुकूलन के दो उदाहरण हैं।

मच्छर ग्रहण - खुला स्रोत MQTT दलाल

एक्लिप्स मॉस्किटो एक खुला स्रोत संदेश दलाल (ईपीएल / ईडीएल) है जो एमक्यूटीटी प्रोटोकॉल संस्करण 5.0, 3.1.1 और 3.1 को लागू करता है। मच्छर हल्के और सभी उपकरणों पर उपयोग के लिए उपयुक्त है: कम-शक्ति वाले एकल-बोर्ड कंप्यूटर से लेकर पूर्ण-विकसित सर्वर तक।

MQTT.js

MQTT.js MQTT प्रोटोकॉल के लिए एक क्लाइंट लाइब्रेरी है, जिसे Node.js और एक ब्राउज़र के लिए जावास्क्रिप्ट में लिखा गया है। यहाँ MQTT.js का उपयोग करके संदेश भेजने का एक उदाहरण दिया गया है:

 var mqtt = require('mqtt') var client = mqtt.connect('mqtt://test.mosquitto.org') client.on('connect', function () { client.subscribe('presence', function (err) { if (!err) { client.publish('presence', 'Hello mqtt') } }) }) client.on('message', function (topic, message) { // message is Buffer console.log(message.toString()) client.end() }) 

MQTTnet

MQTTnet एक उच्च-प्रदर्शन .NET लाइब्रेरी है जो क्लाइंट और MQTT सर्वर (ब्रोकर) दोनों को प्रदान करती है।

MQTT क्लाइंट स्थापना:

 // Create a new MQTT client. var factory = new MqttFactory(); var mqttClient = factory.CreateMqttClient(); 

MQTT क्लाइंट सेटिंग्स कॉन्फ़िगर करने के बाद, आप कनेक्शन स्थापित कर सकते हैं। निम्न कोड दिखाता है कि सर्वर से कैसे जुड़ा जाए:

 // Use WebSocket connection. var options = new MqttClientOptionsBuilder() .WithWebSocketServer("broker.hivemq.com:8000/mqtt") .Build(); await client.ConnectAsync(options); 

आने वाले संदेशों को प्राप्त करें:

 client.UseApplicationMessageReceivedHandler(e => { Console.WriteLine("### RECEIVED APPLICATION MESSAGE ###"); Console.WriteLine($"+ Topic = {e.ApplicationMessage.Topic}"); Console.WriteLine($"+ Payload = {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}"); Console.WriteLine($"+ QoS = {e.ApplicationMessage.QualityOfServiceLevel}"); Console.WriteLine($"+ Retain = {e.ApplicationMessage.Retain}"); Console.WriteLine(); Task.Run(() => client.PublishAsync("hello/world")); }); 

पोस्ट प्रकाशन:

 var message = new MqttApplicationMessageBuilder() .WithTopic("MyTopic") .WithPayload("Hello World") .WithExactlyOnceQoS() .WithRetainFlag() .Build(); await client.PublishAsync(message); 

अधिक उदाहरणों के लिए MQTTnet प्रलेखन और विकि देखें।

एंटरप्राइज-ग्रेड प्रदाताओं के पास मोबाइल एप्लिकेशन, औद्योगिक मशीनों और अन्य IoT उपयोगों की एक विस्तृत श्रृंखला के बीच स्केलेबल मैसेजिंग के लिए ऑफ-द-शेल्फ MQTT सर्वर हैं । यह मार्गदर्शिका आपको बताती है कि उद्यम स्तर दलाल के माध्यम से एमक्यूटीटी का उपयोग कैसे करें।

स्केलिंग के बारे में क्या?

जब MQTT को स्केल करने की बात आती है, तो विचार करने के लिए दो विचार हैं: 1) क्या यह सही प्रोटोकॉल है; 2) प्रोटोकॉल पसंद की परवाह किए बिना, MQTT का उपयोग करने वाले उपकरणों के बीच बढ़ते यातायात को संभालने के लिए बुनियादी ढांचे और नेटवर्क क्षमताओं की क्या आवश्यकता है।

लाइटवेट मशीन-टू-मशीन (LWM2M) एक और प्रोटोकॉल है जिसका उपयोग उद्यम स्तर पर MQTT के साथ किया जा सकता है। MQTT की तुलना में, यह कभी-कभी IoT सिस्टम के लिए बेहतर अनुकूल होता है । MQTT आदर्श रूप से IoT के ट्रायल रन के लिए आदर्श रूप से अनुकूल है, जबकि LWM2M एक दीर्घकालिक, बहुमुखी बुनियादी ढांचे के लिए सुविधाएँ प्रदान करता है। LWM2M भी बेहतर डिवाइस प्रबंधन उपकरण प्रदान करता है जैसे कनेक्शन निगरानी, ​​फर्मवेयर अपडेट और दूरस्थ डिवाइस क्रियाएं। बड़ी संख्या में अप्रबंधित उपकरणों वाले उद्यमों के लिए, जो बड़ी मात्रा में डेटा को एक केंद्रीय प्लेटफ़ॉर्म पर भेजते हैं, LWM2M सबसे अच्छा विकल्प है। फिर भी, हम IoT के बड़े पैमाने पर तैनाती के बारे में बात कर रहे हैं, इसलिए आमतौर पर MQTT एक पर्याप्त विकल्प से अधिक है। इसके अलावा, MQTT अधिक सामान्य है और व्यापक समर्थन है।

अब बुनियादी सुविधाओं की संभावनाओं के बारे में। जब सर्वर लोडिंग की बात आती है, तो एक साथ कनेक्शन की संख्या शायद ही कभी टोंटी होती है। अधिकांश अच्छे MQTT सर्वर / ब्रोकर हजारों समवर्ती कनेक्शनों का समर्थन करते हैं, लेकिन वास्तविक डेटा प्राप्त होने के बाद MQTT सर्वर को संसाधित करने और संदेशों का जवाब देने के लिए आवश्यक कार्यभार क्या है? एक नियम के रूप में, सभी प्रकार की संभावित समस्याएं हैं, जैसे कि डेटाबेस से पढ़ना और लिखना, सर्वर के साथ एकीकरण, प्रत्येक क्लाइंट के लिए संसाधनों का वितरण और प्रबंधन, आदि। जैसे ही एक मशीन लोड से निपटने के लिए बंद हो जाती है, आपको अतिरिक्त सर्वर जोड़ने की आवश्यकता होती है। यह है कि लोड संतुलन के बारे में सोचें, विभिन्न सर्वरों से जुड़े ग्राहकों के बीच संदेश सिंक्रनाइज़ेशन, क्लाइंट की स्थिति तक सामान्यीकृत पहुंच, कनेक्शन समय या ग्राहक से जुड़े विशिष्ट सर्वर की परवाह किए बिना - उत्पाद सूची zhaetsya और यह जारी है।

इस तरह की समस्याओं को एक अलग लेख के लायक है, और हमारे ब्लॉग के इंजीनियरिंग अनुभाग में बहुत सारी जानकारी मिल सकती है। विशेष रूप से, बड़े पैमाने पर रीयल-टाइम मैसेजिंग इन्फ्रास्ट्रक्चर की सर्विसिंग की कुछ जटिलताओं पर लेख देखें।

MQTT के साथ वर्तमान स्थिति क्या है?

अप्रैल 2019 में, OASIS ने MQTT v5.0 को आधिकारिक मानक के रूप में जारी किया। OASIS 600 सदस्य संगठनों और 5,000 व्यक्तिगत सदस्यों का एक गैर-लाभ संघ है।

संस्करण 5.0 कई नई सुविधाओं का परिचय देता है जो वास्तविक समय प्रणाली के डेवलपर्स के लिए रुचि होनी चाहिए। ये नई सुविधाएँ MQTT के वर्तमान संस्करणों के साथ पिछड़ी संगत हैं। उनमें से हैं:

• बेहतर त्रुटि रिपोर्टिंग : रिटर्न कोड अब यह सूचित कर सकते हैं कि डेटा किसी कारण से प्रेषित नहीं हो रहा है। कारण बताने के लिए वैकल्पिक तारों का सहारा लिया जाता है। वे समस्या निवारण निदान में सुधार करने में मदद करते हैं।
  
• शेयरिंग सब्सक्रिप्शन : लोड को संतुलित करने में मदद करने के लिए, सब्सक्रिप्शन को कई क्लाइंट्स के बीच रिसीविंग साइड पर शेयर किया जा सकता है।
  
• संदेश गुण : संस्करण 5.0 संदेश शीर्षलेख के भाग के रूप में मेटाडेटा का परिचय देता है। यह अंतिम उपयोगकर्ता को अतिरिक्त जानकारी दे सकता है या नीचे सूचीबद्ध कुछ अन्य कार्यों की सुविधा प्रदान कर सकता है।
  
• चैनल उपनाम : प्रकाशक प्रसारित करने के लिए बाइट्स की संख्या को कम करने के लिए संख्यात्मक पहचानकर्ताओं वाले चैनलों को बदल सकते हैं।
  
• संदेश की समाप्ति तिथि: संदेश स्वचालित विलोपन के लिए चिह्नित किए जा सकते हैं यदि सिस्टम उन्हें निर्दिष्ट समय के भीतर वितरित करने में सक्षम नहीं है।

नई MQTT 5.0 सुविधाओं की पूरी सूची के लिए, परिशिष्ट C को आधिकारिक मानक पर देखें।

बाजार पर कई उपभोक्ता उपकरणों और सेवाओं के अलावा, MQTT ने सभी आकारों और आकारों के कॉर्पोरेट बुनियादी ढांचे में उपयोग पाया है। ये स्मार्टफोन और टैबलेट, ऊर्जा निगरानी प्रणाली, चिकित्सा उपकरण, तेल रिसाव और रिसाव, मोटर वाहन और एयरोस्पेस उद्योग, साथ ही सामग्री हैंडलिंग, निर्माण, आपूर्ति श्रृंखला, खुदरा और बहुत अधिक में सेंसर और मशीन दृष्टि प्रणाली हैं।

MQTT और Ably

MQTT एक लोकप्रिय, व्यापक रूप से समर्थित और अपेक्षाकृत परिपक्व प्रोटोकॉल है। यह कई वास्तविक समय के अनुप्रयोगों के लिए बहुत अच्छा है, और केवल IoT को तैनात करने के लिए नहीं है। हालाँकि, जैसे-जैसे वास्तविक समय में डेटा उत्पादन और खपत तेजी से बढ़ती रहती है , MQTT हमेशा आपकी स्ट्रीमिंग की जरूरतों को पूरा करने के लिए सही प्रोटोकॉल नहीं हो सकता है। अन्य प्रोटोकॉल के बारे में जानकारी के लिए हमारे रीयलटाइम कॉन्सेप्ट सेक्शन का पालन करें और वे आपकी स्थिति के अनुरूप हैं।

Ably दोनों दिशाओं में Ably के अपने प्रोटोकॉल में अनुवाद के साथ एक ब्रोकर और एक MQTT प्रोटोकॉल एडेप्टर प्रदान करता है, जो आपको किसी भी मौजूदा सिस्टम और कनेक्शन के साथ एकीकृत करने की अनुमति देता है। समर्थित वेबसॉकेट्स, HTTP, SSE, gRPC (विकास के तहत), STOMP, AMQP और अन्य प्रोटोकॉल वास्तविक समय में वितरित संदेश संरचना के आयोजन के लिए। 40 से अधिक एसडीके क्लाइंट लाइब्रेरी हैं और मालिकाना वास्तविक समय प्रोटोकॉल के लिए समर्थन करते हैं।