मशीनें कैसे संवाद करती हैं - एमक्यूटीटी प्रोटोकॉल

पिछले लेख में, हमने मोडबस प्रोटोकॉल को देखा, जो एम 2 एम इंटरैक्शन के लिए वास्तविक उद्योग मानक है। 1979 में वापस विकसित, इसमें कई महत्वपूर्ण कमियां हैं जो MQTT हल करती हैं।

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

एमक्यूटीटी प्रोटोकॉल की मुख्य विशेषताएं:

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

लेख में, हम एमक्यूटीटी और मोडबस की तुलना करेंगे, प्रोटोकॉल संरचना, बुनियादी अवधारणाओं का विश्लेषण करेंगे, और अस्थिर इंटरनेट कनेक्शन में एक उदाहरण के रूप में क्लाउड एमक्यूटीटी ब्रोकर का उपयोग करने का प्रयास करेंगे।

MQTT प्रोटोकॉल इतिहास

MQTT को 1999 में IBM द्वारा विकसित किया गया था, और शुरू में इसके समाधान के लिए आंतरिक रूप से उपयोग किया गया था।

नवंबर 2011 में, आईबीएम और यूरोटेक ने एक्लिप्स एम 2 एम वर्किंग ग्रुप में अपनी भागीदारी की घोषणा की और एमक्यूटीटी कोड को एक्लिप्स पाहो प्रोजेक्ट में ट्रांसफर कर दिया।

2013 में, OASIS (संरचित सूचना मानकों की उन्नति के लिए संगठन) संघ ने MQTT प्रोटोकॉल के मानकीकरण की प्रक्रिया शुरू की। इस बिंदु तक, प्रोटोकॉल विनिर्देश एक नि: शुल्क लाइसेंस के तहत प्रकाशित किया गया है, और यूरोटेक (जिसे पहले अरकॉम के रूप में जाना जाता है) जैसी कंपनियां पहले से ही अपने उत्पादों में प्रोटोकॉल का उपयोग करती हैं।

अक्टूबर 2014 में, OASIS ने पहला आधिकारिक MQTT प्रोटोकॉल मानक प्रकाशित किया।

2016 में, मानकीकरण आईएसओ के लिए अंतर्राष्ट्रीय संगठन द्वारा प्रोटोकॉल का मानकीकरण किया गया और आईएसओ / आईईसी 20922 नंबर प्राप्त किया।

2014 के बाद से, प्रोटोकॉल में रुचि तेजी से बढ़ने लगी और, Google ट्रेंड्स शेड्यूल को देखते हुए, आज यह मोडबस में रुचि से अधिक है।


Google रुझान बेंचमार्क

मूल अवधारणाएँ

MQTT में क्लाइंट-सर्वर आर्किटेक्चर है। मैसेजिंग एक केंद्रीय सर्वर के माध्यम से होता है जिसे दलाल कहा जाता है। सामान्य परिस्थितियों में, ग्राहक एक दूसरे के साथ सीधे संवाद नहीं कर सकते हैं, और सभी डेटा एक्सचेंज एक दलाल के माध्यम से होते हैं।

ग्राहक डेटा प्रदाता (प्रकाशक) और डेटा प्राप्तकर्ता (सब्सक्राइबर) के रूप में कार्य कर सकते हैं। रूसी अनुवाद में, इन शब्दों को अक्सर प्रकाशक और ग्राहक के रूप में अनुवादित किया जाता है, लेकिन भ्रम से बचने के लिए, हम केवल मूल शब्दावली का उपयोग करेंगे।


MQTT प्रोटोकॉल में, क्लाइंट एक दूसरे के साथ सेंट्रल नोड के माध्यम से संवाद करते हैं

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

आने वाले टीसीपी कनेक्शन के लिए मानक MQTT ब्रोकर पोर्ट 1883 है । एक सुरक्षित एसएसएल कनेक्शन का उपयोग करते समय, पोर्ट 8883 का उपयोग किया जाता है ।

दलाल

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

प्रकाशक / सब्सक्राइबर

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

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

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


प्रकाशक ब्रोकर को डेटा भेजता है, सब्सक्राइबर इस डेटा के अपडेट के लिए सदस्यता लेता है

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

विषय

MQTT संस्थाओं की पहचान करने के लिए विषयों का उपयोग करता है, रूसी अनुवाद में उन्हें चैनल भी कहा जाता है। विषय UTF8 वर्णों से मिलकर होते हैं, और एक UNIX फ़ाइल सिस्टम के समान एक ट्री संरचना होती है। यह मानव-पठनीय रूप में संस्थाओं के नामकरण के लिए एक सुविधाजनक तंत्र है।

MQTT में विषयों का एक उदाहरण

#     home/kitchen/temperature #     home/sleeping-room/temperature #     home/outdoor/light 

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

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

एक एकल-स्तरीय वाइल्डकार्ड एक + द्वारा इंगित किया गया है।

उदाहरण के लिए, घर के सभी कमरों में तापमान सेंसर से डेटा प्राप्त करने के लिए, ग्राहक को इस तरह के विषय की सदस्यता लेने की आवश्यकता होती है:

 home/+/temperature 

परिणामस्वरूप, वह ऐसे सेंसर से डेटा प्राप्त करने के लिए सदस्यता लेगा:

 home/kitchen/temperature home/sleeping-room/temperature home/living-room/temperature home/outdoor/temperature 

एक बहु-स्तरीय वाइल्डकार्ड प्रतीक " # " द्वारा इंगित किया गया है।
घर के सभी कमरों में सभी सेंसर से डेटा प्राप्त करने का एक उदाहरण:

 home/# 

इस तरह के विषय की सदस्यता लेने से आप ऐसे सेंसर से डेटा प्राप्त कर सकते हैं:

 home/kitchen/temperature home/kitchen/humidity home/kitchen/light home/sleeping-room/temperature home/sleeping-room/humidity home/sleeping-room/light .... 

ग्राहक की पहचान

एक्सेस कंट्रोल के लिए, MQTT मोडबस प्रोटोकॉल के विपरीत क्लाइंट प्रमाणीकरण प्रदान करता है, जिसमें ऐसा फ़ंक्शन नहीं होता है। निम्नलिखित क्षेत्रों का उपयोग अभिगम नियंत्रण के लिए किया जाता है:

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

उपयोगकर्ता नाम - (वैकल्पिक क्षेत्र) प्रमाणीकरण के लिए, यूटीएफ -8 प्रारूप में लॉगिन करें। अनोखा नहीं हो सकता। उदाहरण के लिए, ग्राहकों का एक समूह एक ही उपयोगकर्ता नाम / पासवर्ड के साथ लॉग इन कर सकता है।

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

पैकेज संरचना

जैसा कि ऊपर उल्लेख किया गया है, MQTT प्रोटोकॉल में, क्लाइंट हमेशा कनेक्शन प्राप्त करते हैं, चाहे वे प्राप्तकर्ता (सब्सक्राइबर) हों या डेटा के आपूर्तिकर्ता (प्रकाशक)। हम उस कनेक्शन के साथ पैकेट का विश्लेषण करेंगे जो विरेचक कार्यक्रम का उपयोग करके इंटरसेप्ट किया गया था।


MQTT पैकेट एक अनएन्क्रिप्टेड चैनल पर प्रसारित होता है

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

हैडर

संदेश प्रकार कनेक्ट (कमांड 0x0001) है, जो ब्रोकर के साथ संबंध स्थापित करता है। मुख्य टीमें: कनेक्ट, डिस्कनेक्ट, प्रकाशित करें, सदस्यता लें, सदस्यता समाप्त करें। पावती आदेश भी हैं, जीवित रखें, आदि।

फ़्लैग DUP - का अर्थ है कि संदेश को फिर से दर्ज किया गया है, इसका उपयोग केवल संदेश प्रकार PUBLISH, SUBSCRIBE, UNSUBSCRIBE, PUBREL में किया जाता है, ऐसे मामलों के लिए जब दलाल को पिछले संदेश की प्राप्ति की पुष्टि नहीं मिली थी।
QoS स्तर - सेवा की गुणवत्ता का ध्वज। हम इस विषय पर बाद में और विस्तार से चर्चा करेंगे।
रिटेन - रिटेन फ़्लैग के साथ प्रकाशित डेटा ब्रोकर पर संग्रहीत होता है। इस विषय पर बाद की सदस्यता के बाद, दलाल तुरंत इस ध्वज के साथ एक संदेश भेजेगा। केवल प्रकाशित करें के संदेश में उपयोग किया जाता है।

व्यावहारिक उपयोग

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

कई क्लाउड प्रदाता MQTT ब्रोकर सेवाएं प्रदान करते हैं, जैसे Microsoft Azure IoT हब , Amazon AWS IoT , और अन्य। इस उदाहरण में, हम Cloudmqtt.com सेवा का उपयोग करेंगे, क्योंकि इसका सबसे सरल पंजीकरण है, और प्रशिक्षण के लिए एक मुफ्त टैरिफ पर्याप्त है।

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


क्लाउड प्रदाता के व्यक्तिगत खाते में MQTT ब्रोकर एक्सेस विवरण

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

mosquitto_sub - ग्राहक की उपयोगिता
mosquitto_pub - प्रकाशक क्लाइंट उपयोगिता

सबसे पहले, एक ग्राहक के रूप में ब्रोकर से कनेक्ट करें, और विषय से डेटा प्राप्त करने के लिए सदस्यता लें
habr / परीक्षण / यादृच्छिक ।

 mosquitto_sub -d --capath /etc/ssl/certs/ --url mqtts://hwjspxxt:7oYugN7Fa5Aa@postman.cloudmqtt.com:27529/habr/test/random Client mosq/zEPZz0glUiR4aEipZA sending CONNECT Client mosq/zEPZz0glUiR4aEipZA received CONNACK (0) Client mosq/zEPZz0glUiR4aEipZA sending SUBSCRIBE (Mid: 1, Topic: habr/test/random, QoS: 0, Options: 0x00) Client mosq/zEPZz0glUiR4aEipZA received SUBACK 

यह देखा जा सकता है कि कनेक्शन सफल था, और हमने हब्र / परीक्षण / यादृच्छिक विषय की सदस्यता ली थी, और अब हम दलाल से इस विषय में डेटा की प्रतीक्षा कर रहे हैं।

चूंकि एसएसएल कनेक्शन का उपयोग किया जाता है, इसलिए प्रमाण पत्र को सत्यापित करने के लिए, आपको उस पथ को निर्दिष्ट करना होगा जिसके द्वारा कार्यक्रम रूट एन्क्रिप्शन प्रमाण पत्र के लिए दिखेगा। चूँकि हमारे उदाहरण में सेवा एक विश्वसनीय प्रमाणीकरण प्राधिकारी द्वारा जारी किए गए प्रमाण पत्र का उपयोग करती है, इसलिए हम रूट प्रमाणपत्र के लिए सिस्टम स्टोर के लिए पथ को इंगित करते हैं: - -पैथ / आदि / एसएसएल / सेर /

स्व-हस्ताक्षरित प्रमाण पत्र के मामले में, आपको वांछित सीए को पथ निर्दिष्ट करना होगा। SSL कनेक्शन के लिए URI प्रारूप में अंतर पर विचार करना भी महत्वपूर्ण है - mqtt s : //, और गैर-एन्क्रिप्टेड कनेक्शन - mqtt: //। प्रमाणपत्र सत्यापन त्रुटि की स्थिति में, प्रोग्राम त्रुटि संदेश के बिना समाप्त हो जाता है। अधिक विस्तृत आउटपुट के लिए, आप -debug स्विच का उपयोग कर सकते हैं

अब पहले कार्यक्रम को बाधित किए बिना विषय में डेटा प्रकाशित करने का प्रयास करें।

 mosquitto_pub -d --capath /etc/ssl/certs/ --url mqtt://hwjspxxt:7oYugN7Fa5Aa@postman.cloudmqtt.com:27529/habr/test/random -m " !" Client mosq/sWjh9gf8DRASrRZjk6 sending CONNECT Client mosq/sWjh9gf8DRASrRZjk6 received CONNACK (0) Client mosq/sWjh9gf8DRASrRZjk6 sending PUBLISH (d0, q0, r0, m1, 'habr/test/random', ... (22 bytes)) Client mosq/sWjh9gf8DRASrRZjk6 sending DISCONNECT 

यह देखा जा सकता है कि डेटा सर्वर द्वारा सफलतापूर्वक प्राप्त किया गया था और वांछित विषय में प्रकाशित किया गया था। उसी समय, पहली विंडो में जिसमें मच्छर_सुब कार्यक्रम चल रहा है, हम देखते हैं कि संदेश कैसे प्राप्त किया गया था, यहां तक ​​कि यूनिकोड भी काम कर रहा है, संदेश रूसी में है।

 Client mosq/zEPZz0glUiR4aEipZA received PUBLISH (d0, q0, r0, m0, 'habr/test/random', ... (22 bytes))  ! 

क्यूओएस और डिलीवरी की गारंटी

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

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

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

QoS 2: बिल्कुल एक बार - एक की गारंटी । QoS ध्वज, जो पुष्टिकरण और प्रकाशन के पूरा होने (PUBREC, PUBREL, PUBCOMP) के लिए अतिरिक्त प्रक्रियाओं के उपयोग के माध्यम से संदेश वितरण की उच्चतम गारंटी प्रदान करता है। उन परिस्थितियों के लिए लागू जहां सेंसर से डेटा के किसी भी नुकसान और दोहराव को बाहर करना आवश्यक है। उदाहरण के लिए, जब किसी प्राप्त संदेश से अलार्म चालू होता है, तो एक आपातकालीन कॉल किया जाता है।

खराब संचार का अनुकरण करने के लिए, दोनों ग्राहकों को बंद करें और उच्चतम QoS प्राथमिकता के साथ एक संदेश भेजने का प्रयास करें, और रिटेन विकल्प भी जोड़ें ताकि भेजे गए संदेश दलाल पर सहेजे जाएं।

 mosquitto_pub --retain --qos 2 -d --capath /etc/ssl/certs/ --url mqtt://hwjspxxt:7oYugN7Fa5Aa@postman.cloudmqtt.com:27529/habr/test/random -m "  !" Client mosq/Xwhua3GAyyY9mMd05V sending CONNECT Client mosq/Xwhua3GAyyY9mMd05V received CONNACK (0) Client mosq/Xwhua3GAyyY9mMd05V sending PUBLISH (d0, q2, r1, m1, 'habr/test/random', ... (37 bytes)) Client mosq/Xwhua3GAyyY9mMd05V received PUBREC (Mid: 1) Client mosq/Xwhua3GAyyY9mMd05V sending PUBREL (m1) Client mosq/Xwhua3GAyyY9mMd05V received PUBCOMP (Mid: 1, RC:0) Client mosq/Xwhua3GAyyY9mMd05V sending DISCONNECT 

अब, कुछ समय के बाद, हमारा प्राप्तकर्ता अंत में इंटरनेट से कनेक्शन स्थापित करने में सक्षम था और ब्रोकर से जुड़ा था:

 mosquitto_sub -d --capath /etc/ssl/certs/ -d --url mqtts://hwjspxxt:7oYugN7Fa5Aa@postman.cloudmqtt.com:27529/habr/test/random Client mosq/VAzcLVMB1MiWhYxoJS sending CONNECT Client mosq/VAzcLVMB1MiWhYxoJS received CONNACK (0) Client mosq/VAzcLVMB1MiWhYxoJS sending SUBSCRIBE (Mid: 1, Topic: habr/test/random, QoS: 0, Options: 0x00) Client mosq/VAzcLVMB1MiWhYxoJS received SUBACK Subscribed (mid: 1): 0 Client mosq/r6UwPnDvx8aNInpPF6 received PUBLISH (d0, q0, r1, m0, 'habr/test/random', ... (37 bytes))   ! 

निष्कर्ष

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