XMPP पब्लिश करना / ट्विस्टेड के साथ सब्सक्राइब करना

आपका दिन शुभ हो! इस लेख में, मैं बात करूँगा कि XMPP का उपयोग करके Twisted और Wokkel लाइब्रेरी का उपयोग करके मूल प्रकाशन / सदस्यता कार्यान्वयन कैसे करें। XMPP XEP-0060 एक्सटेंशन के लिए पब / उप धन्यवाद का समर्थन करता है। पब / उप का उपयोग करके, आप घटना और कई अन्य लोगों के बारे में सभी प्रतिभागियों को सूचित करने की समस्या को हल कर सकते हैं। यह ज्ञात है कि Apple अपने अधिसूचना सर्वर के अंदर Wokkel- आधारित पब / उप का उपयोग करता है, लेकिन बाद में उस पर अधिक।

क्यों प्रकाशित / सदस्यता लें?

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

उपकरण

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

उदाहरण

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



पहले आपको XMPPClient क्लास की एक ऑब्जेक्ट बनाने की आवश्यकता है, जो कि एक सेवा है (ट्विस्टेड शब्दावली में)। वह जब्बार सर्वर और कनेक्शन प्रबंधन पर प्राधिकरण के लिए जिम्मेदार है। PubSubClient या PubSubService वर्ग का एक ऑब्जेक्ट हमें पब / प्रोटोकॉल प्रोटोकॉल स्तर पर बातचीत करने की क्षमता प्रदान करेगा। हम setHandlerParent कहते हैं ताकि प्रोटोकॉल और सेवा एक दूसरे के साथ बातचीत कर सकें। हम सेवा शुरू करते हैं। प्रोटोकॉल पब / उप से संबंधित संदेशों के लिए थ्रेड को सुनना शुरू कर देता है; जब यह उपरोक्त संदेश प्राप्त करता है, तो यह संबंधित हैंडलर कहता है। अगला कदम सेवा वर्ग के कार्यान्वयन पर विचार करना है।

def मुख्य ( ) :

लॉग इन करें। StartLogging ( sys । स्टडआउट )

विकल्प, आर्ग = parse_args ( )

jid, resource, password = args

सेवा = विकल्प। सेवा

फुलजीद = जब्बार। जिद इंटर्नजिड ( jid + '/' + संसाधन )

परिवहन = XMPPClient ( फुलजिड, पासवर्ड )

परिवहन। logTraffic = सत्य

प्रोटोकॉल = ग्राहक ( jabber। jid । internJID ( सेवा ) ) यदि सेवा और सेवा ( )

प्रोटोकॉल। सेटहैंडलरपेंट ( परिवहन )

परिवहन। प्रारंभ सेवा ( )

रिएक्टर। चलाएं ( )

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

वर्ग सेवा ( PubSubService ) :

def __init__ ( स्व ) :

PubSubService। __in__ ( स्व )

स्व ._ सदस्यताएँ = { }



डीईएल प्रकाशन ( स्वयं , अनुरोधकर्ता, सेवा, नोडडेंटिफायर, आइटम ) :

स्व । sendData ( आइटम )

वापसी करना सफल ( कोई नहीं )



डीईएफ़ सदस्यता ( स्वयं , अनुरोधकर्ता, सेवा, नोडडेंटिफायर, ग्राहक ) :

यदि स्व में ग्राहक हैं ।_ सदस्यताएँ:

जानकारी = स्व ._ सदस्यताएँ [ ग्राहक ]

और :

जानकारी = सदस्यता ( NODE_NAME, ग्राहक, 'सदस्यता प्राप्त' )

स्वयं ._ सदस्यताएँ [ ग्राहक ] = जानकारी

वापसी करना सफल ( जानकारी )



डीएड सेंडटा ( स्वयं , आइटम ) :

प्रेषक = [ ]

स्व ._ सदस्यता में सदस्यता के लिए । मान ( ) :

sendList। append ( [ सदस्यता। ग्राहक , कोई नहीं , आइटम ] )

स्व । सूचनाप्रकाशक ( स्व- अभिभावक । jid , NODE_NAME, sendList )

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

वर्ग ग्राहक ( PubSubClient ) :

def __init__ ( स्वयं , सेवा ) :

PubSubClient। __in__ ( स्व )

स्वयं .__ सेवा = सेवा



def कनेक्शन

PubSubClient। कनेक्शनयुक्त ( स्व )

d = स्व । सदस्यता लें ( स्व । _ सेवा, NODE_NAME, स्व । माता-पिता । jid )

घ। addCallback ( लंबो सफलता: कार्य। लूपिंगकॉल ( SendGeneratedData, आत्म ) )

घ। AddCallback ( लैम्ब्डा lc: lc। प्रारंभ ( 5 , अब = सत्य ) )



डीईएट आइटम हटाए गए ( स्वयं , ईवेंट ) :

घटना में आइटम के लिए । आइटम :

लॉग इन करें। संदेश ( आइटम। getAttribute ( 'प्रेषक' ) + 'भेजता है' +

आइटम। getAttribute ( 'संदेश' ) + 'पर' आइटम। getAttribute ( 'समय' )



डीएड सेंडटा ( स्वयं , आइटम ) :

स्व । प्रकाशित ( स्वयं .__ सेवा, NODE_NAME, आइटम )

def sendeneratedData ( प्रोटोकॉल ) :

तत्व = तत्व ( ( कोई नहीं , 'आइटम' ) )

तत्व। विशेषताएँ [ 'प्रेषक' ] = प्रोटोकॉल। माता-पिता। जिद पूर्ण ( )

तत्व। विशेषताएँ [ 'समय' ] = समय। strftime ( "% H:% M:% S" , समय। स्थानीय समय ( ) )

तत्व। विशेषताएँ [ 'संदेश' ] = 'हैलो!'

प्रोटोकॉल। sendData ( [ तत्व ] )

स्रोत कोड यहां देखें

ऑपरेशन की जांच करने के लिए, आपको आवश्यकता है:

सर्वर शुरू करें: pubsub.py test@example.com सर्वर पासवर्ड

दो क्लाइंट चलाएं: pubsub.py --service test@example.com/server test@example.com client1 पासवर्ड

pubsub.py --service test@example.com/server test@example.com client2 पासवर्ड

Apple को इससे क्या लेना देना है?

जो हमने अभी किया है वह सैकड़ों पब / उप विशेषताओं में से एक को दिखाने वाला एक उदाहरण है। यदि हम विनिर्देशन की ओर मुड़ते हैं, तो हम देख सकते हैं कि हमारा उदाहरण लीफ नोड के प्रकार से मेल खाता है, कॉन्फ़िगरेशन persistItems = झूठी डिलीवरी के साथ = सही लोड और एक ओपन एक्सेस मॉडल, संबद्धता के लिए समर्थन के बिना, खोज, अन्य नोड्स बनाने की संभावना आदि। कल्पना कीजिए कि पूरे पब / उप विनिर्देश या यहां तक ​​कि आवश्यक भाग को लागू करना कितना मुश्किल है। लेकिन वोक्काल के लेखक राल्फ़ मीजेर ने हमारे कार्य को सरल बनाया और इदावॉल को लिखा। इदावल वोकेल के लिए एक ऐड-ऑन है। यह लगभग XEP-0060 का पूरी तरह से समर्थन करता है और इसमें http के माध्यम से संचार करने की क्षमता है। Idavoll का उपयोग Apple द्वारा एक अधिसूचना सर्वर के रूप में किया जाता है। इस तथ्य को यहां जांचा जा सकता है ।

निष्कर्ष

ट्विस्टेड सीखने के लिए, मैं आधिकारिक दस्तावेज और krondo.com/?page_id=1327 की सिफारिश करता हूं

दुर्भाग्य से, वोकेल पर बहुत कम जानकारी है, लेकिन इदावल पर बिल्कुल भी नहीं है, इसलिए केवल उत्पन्न प्रलेखन रहता है।

सीखने में सफलता!