पायथन में लिनक्स एपोल कैसे लागू करें

लेख का वर्णन है:

• सॉकेट उदाहरणों को अवरुद्ध करना
• अतुल्यकालिक सॉकेट्स और लिनक्स एपोल के लाभ
• एपोल के माध्यम से अतुल्यकालिक सॉकेट उपयोग के उदाहरण
• प्रदर्शन के मुद्दे
• स्रोत कोड

परिचय

संस्करण 2.6 के बाद से, पायथन में लिनक्स एपोल लाइब्रेरी के साथ काम करने के लिए एक एपीआई शामिल है। यह लेख संक्षेप में इस एपीआई को पायथन 3 कोड उदाहरणों के साथ प्रदर्शित करता है।

अनुवादक से।
मैंने यथासंभव अंग्रेजी शब्दों का दुरुपयोग नहीं करने की कोशिश की। तो "रजिस्टर / अपंजीकृत" "सदस्यता / सदस्यता समाप्त", "कंसोल पर प्रिंट करें" - "कंसोल में आउटपुट" बन गया। मैंने "उत्पादन सर्वर" को "लोड किए गए सर्वर" के रूप में अनुवाद करने का फैसला किया, क्योंकि "उत्पादन पर सर्वर" से बेहतर कुछ भी नहीं है। "थ्रेड" का अनुवाद "थ्रेड" के रूप में किया जाता है, न कि "थ्रेड" के रूप में।
मैंने एक निश्चित अनुवाद का केवल एक बार का उदाहरण देते हुए घटनाओं, मोड और झंडे के नामों का अनुवाद नहीं करने का फैसला किया।
हालांकि यह लिखा है कि कोड पायथन 3 के लिए है, सब कुछ अजगर 2.6 में भी ठीक काम करता है।

सॉकेट उदाहरणों को अवरुद्ध करना

पहला उदाहरण एक साधारण पायथन 3.0 सर्वर है जो आने वाले HTTP अनुरोधों के लिए पोर्ट 8080 पर सुनता है, उन्हें कंसोल को आउटपुट करता है, और क्लाइंट को एक प्रतिक्रिया HTTP संदेश भेजता है।

• लाइन 9: सर्वर सॉकेट बनाना।
• पंक्ति 10: बाँध () को पंक्ति 11 पर क्रियान्वित करने की अनुमति दें, भले ही एक अन्य कार्यक्रम हाल ही में उसी बंदरगाह को सुने। इसके बिना, प्रोग्राम पहले से लॉन्च किए गए प्रोग्राम में उसी पोर्ट के साथ काम खत्म करने के बाद 1-2 मिनट के लिए पोर्ट के साथ काम करने में सक्षम नहीं होगा।
• पंक्ति 11: हम इस मशीन के सभी उपलब्ध IPv4 पतों के लिए पोर्ट 8080 पर सर्वर सॉकेट को लटकाते हैं।
• पंक्ति 12: ग्राहकों से आने वाले कनेक्शन को स्वीकार करने के लिए सर्वर सॉकेट को बताएं।
• लाइन 14: जब तक एक इनकमिंग कनेक्शन प्राप्त नहीं हो जाता है, तब तक प्रोग्राम इस बिंदु पर रुकेगा। जब ऐसा होता है, तो सर्वर सॉकेट एक नया सॉकेट बनाएगा जिसका उपयोग ग्राहक के साथ संवाद करने के लिए इस मशीन पर किया जाएगा। इस नए सॉकेट को क्लाइंटकनेक्शन ऑब्जेक्ट द्वारा दर्शाया गया है, जिसे एक स्वीकार () कॉल द्वारा वापस किया जाता है। एड्रेस ऑब्जेक्ट में IP पता और रिमोट मशीन का पोर्ट नंबर होता है।
• लाइनें 15-17: हम वह डेटा बनाते हैं जो क्लाइंट को HTTP रिक्वेस्ट को पूरा करने के लिए भेजा जाएगा। HTTP प्रोटोकॉल यहाँ वर्णित है ।
• पंक्ति 18: हम कंसोल को कार्रवाई की शुद्धता की जांच के रूप में प्रिंट करते हैं।
• लाइन 19: हम ग्राहक को जवाब भेजते हैं।
• लाइनें 20-22: क्लाइंट कनेक्शन को सुनने वाले सर्वर सॉकेट की तरह बंद करें।

आधिकारिक HOWTO में पायथन में सॉकेट प्रोग्रामिंग का अधिक विस्तृत वर्णन है।

उदाहरण 1

कॉपी सोर्स | HTML कॉपी करें

1. आयात सॉकेट
3. EOL1 = b '\ n \ n'
4. EOL2 = b '\ n \ r \ n'
5. प्रतिक्रिया = b 'एचटीटीपी / 1.0 200 ओके \ r \ n दिनांक: सोम, 1 जनवरी 1996 01:01:01 GMT \ r \'
6. प्रतिक्रिया + = b 'सामग्री-प्रकार: पाठ / सादा \ r \ n नियंत्रण-लंबाई: 13 \ r \ n \ r \ n'
7. प्रतिक्रिया + = b 'हैलो, दुनिया!'
9. serverocket = सॉकेट । सॉकेट ( सॉकेट .AF_INET, सॉकेट .SOCK_STREAM)
10. serverocket.setsockopt ( सॉकेट .SOL_SOCKET, सॉकेट .SO_REUSEADDR, 1
11. serverocket.bind (( '0.0.0.0' , 8080 ))
12. serverocket.listen ( 1 )
14. कनेक्शन, पते = serverocket.accept ()
15. निवेदन = b ''
16. जबकि EOL1 अनुरोध में नहीं है और EOL2 अनुरोध में नहीं है :
17. अनुरोध + = connectiontoclient.recv ( 1024 )
18. प्रिंट (request.decode ())
19. connectiontoclient.send (प्रतिक्रिया)
20. connectiontoclient.close ()
22. serverocket.close ()

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

उदाहरण 2

कॉपी सोर्स | HTML कॉपी करें

1. आयात सॉकेट
3. EOL1 = b '\ n \ n'
4. EOL2 = b '\ n \ r \ n'
5. प्रतिक्रिया = b 'एचटीटीपी / 1.0 200 ओके \ r \ n दिनांक: सोम, 1 जनवरी 1996 01:01:01 GMT \ r \'
6. प्रतिक्रिया + = b 'सामग्री-प्रकार: पाठ / सादा \ r \ n नियंत्रण-लंबाई: 13 \ r \ n \ r \ n'
7. प्रतिक्रिया + = b 'हैलो, दुनिया!'
9. serverocket = सॉकेट । सॉकेट ( सॉकेट .AF_INET, सॉकेट .SOCK_STREAM)
10. serverocket.setsockopt ( सॉकेट .SOL_SOCKET, सॉकेट .SO_REUSEADDR, 1
11. serverocket.bind (( '0.0.0.0' , 8080 ))
12. serverocket.listen ( 1 )
14. कोशिश करें :
15. जबकि सच:
16. कनेक्शन, पते = serverocket.accept ()
17. निवेदन = b ''
18. जबकि EOL1 अनुरोध में नहीं है और EOL2 अनुरोध में नहीं है :
19. अनुरोध + = connectiontoclient.recv ( 1024 )
20. प्रिंट ( '-' * 40 + '\ n' + request.decode () [: - 2 ])
21. connectiontoclient.send (प्रतिक्रिया)
22. connectiontoclient.close ()
23. अंत में :
24. serverocket.close ()

अतुल्यकालिक सॉकेट्स और लिनक्स एपोल के लाभ

उदाहरण 2 में दिखाए गए सॉकेट्स को ब्लॉकिंग सॉकेट्स कहा जाता है क्योंकि पायथन प्रोग्राम किसी घटना के आने तक निष्पादन को रोक देता है। क्लाइंट से कनेक्शन प्राप्त होने तक लाइन 16 पर स्वीकार () कॉल अवरुद्ध है। जब तक क्लाइंट से डेटा प्राप्त नहीं किया जाता है (या जब तक डेटा प्राप्त नहीं होता है) तब तक 19 रीव्यू () कॉल ऑन है। लाइन 21 पर क्लाइंट को भेजे गए सभी डेटा को लिनक्स भेजने की कतार में जोड़ने से पहले सेंड () कॉल को ब्लॉक कर दिया जाता है।

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

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

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

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

एपोल के माध्यम से अतुल्यकालिक सॉकेट उपयोग के उदाहरण

प्रोग्राम जो एपोल का उपयोग करते हैं, अक्सर निम्नानुसार काम करते हैं:

1. एक एपोल ऑब्जेक्ट बनाया जाता है।
2. एपोल ऑब्जेक्ट को विशिष्ट सॉकेट पर विशिष्ट घटनाओं के लिए देखने का निर्देश दिया जाता है।
3. एपोल ऑब्जेक्ट से पूछा जाता है कि पिछले पोल के बाद से निर्दिष्ट घटनाओं में कौन सी कुर्सियां ​​हैं
4. इन सॉकेट्स पर कुछ क्रियाएं की जाती हैं।
5. एपोल ऑब्जेक्ट को सॉकेट्स और / या देखी गई घटनाओं की सूची को संशोधित करने का निर्देश दिया जाता है।
6. पूरा करने के लिए चरण 3 को 5 से दोहराएं
7. नष्ट कर दी गई एपोल वस्तु

उदाहरण 3 एसिंक्रोनस सॉकेट्स का उपयोग करके उदाहरण 2 की कार्यक्षमता को दोहराता है। एक कार्यक्रम अधिक जटिल है क्योंकि एक धागा बदले में कई ग्राहकों के साथ बातचीत करता है।

• पंक्ति 1: चयनित मॉड्यूल में एपोल कार्यक्षमता है।
• पंक्ति 13: डिफ़ॉल्ट ब्लॉकिंग सॉकेट्स को गैर-अवरोधक (एसिंक्रोनस) मोड में उपयोग किया जाना चाहिए।
• पंक्ति 15: एक एपोल ऑब्जेक्ट बनाना।
• लाइन 16: सर्वर सॉकेट पर घटनाओं को पढ़ने के लिए सदस्यता लें। जब सर्वर सॉकेट कनेक्शन को स्वीकार करता है तो एक रीड इवेंट होता है।
• लाइन 19: कनेक्शन डिक्शनरी में उनके संबंधित नेटवर्क कनेक्शन ऑब्जेक्ट्स के लिए फाइल डिस्क्रिप्टर (पूर्णांक) मैप होते हैं।
• पंक्ति 21: एपोल ऑब्जेक्ट को यह पता लगाने के लिए छोड़ देना कि क्या कोई अपेक्षित घटना हुई है। पैरामीटर "1" इंगित करता है कि हम 1 सेकंड तक की घटना के लिए इंतजार करने के लिए तैयार हैं। यदि ब्याज की कोई भी घटना पहले होती है, तो क्वेरी तुरंत इन घटनाओं की सूची वापस कर देगी।
• पंक्ति 22: घटनाओं को ट्यूपल्स के क्रम से लौटाया जाता है ( फाइलो , इवेंट कोड )। फाइलो फाइल डिस्क्रिप्टर का एक पर्याय है और हमेशा एक पूर्णांक होता है।
• पंक्ति 23: यदि सर्वर सॉकेट पर कोई रीड ईवेंट हुआ है, तो आप एक नया क्लाइंट सॉकेट बना सकते हैं।
• लाइन 25: नए सॉकेट को नॉन-ब्लॉकिंग मोड पर सेट करें।
• पंक्ति 26: नए सॉकेट पर ईवेंट ( EPOLLIN ) पढ़ने के लिए सदस्यता लें।
• पंक्ति 31: यदि क्लाइंट सॉकेट पर कोई रीड ईवेंट हुआ है, तो हम क्लाइंट से आए नए डेटा को पढ़ते हैं।
• पंक्ति 33: अनुरोध प्राप्त करने के बाद, पढ़ने की घटनाओं से सदस्यता समाप्त करें और घटनाओं को लिखने के लिए सदस्यता लें ( EPOLLOUT )। ये घटनाएँ तब होती हैं जब आप क्लाइंट को प्रतिक्रिया डेटा भेज सकते हैं।
• पंक्ति 34: हम एक अनुरोध प्रिंट करते हैं, जिसमें दिखाया जाता है कि ग्राहकों के बीच स्विच करने के बावजूद, डेटा को एक साथ इकट्ठा किया जा सकता है और एक संदेश के रूप में संसाधित किया जा सकता है।
• पंक्ति 35: यदि क्लाइंट सॉकेट पर कोई रिकॉर्डिंग ईवेंट हुआ है, तो आप क्लाइंट को नया डेटा भेजने का प्रयास कर सकते हैं।
• लाइनें 36-38: एक समय में बैचों में प्रतिक्रिया डेटा भेजना जब तक कि पूरी प्रतिक्रिया भेजने के लिए ऑपरेटिंग सिस्टम को जमा नहीं की गई हो।
• पंक्ति 39: प्रतिक्रिया पूरी तरह से भेजे जाने के बाद, हम आगे पढ़ने या लिखने की घटनाओं से सदस्यता समाप्त कर लेते हैं।
• लाइन 40: एक सॉकेट में शटडाउन कॉलिंग कनेक्शन को स्पष्ट रूप से बंद करने के लिए आवश्यक नहीं है। यह उदाहरण क्लाइंट को पहले कनेक्शन को पूरा करने के लिए मजबूर करने के लिए इसका उपयोग करता है। शटडाउन कॉल क्लाइंट को बताता है कि यह अब डेटा नहीं भेजेगा या प्राप्त नहीं करेगा और इसके भाग के लिए सॉकेट को बंद करना अच्छा होना चाहिए।
• लाइन 41: HUP (हैंग-अप, हैंग) ईवेंट रिपोर्ट करता है कि क्लाइंट सॉकेट डिस्कनेक्ट हो गया है (बंद था), यानी इसे बंद कर दिया जाना चाहिए। HUP ईवेंट की सदस्यता लेने की आवश्यकता नहीं है। वे हमेशा सॉकेट पर होते हैं जिन्हें एपोल ऑब्जेक्ट में हस्ताक्षरित किया जाता है।
• लाइन 42: इस सॉकेट में घटनाओं से सदस्यता समाप्त करें।
• पंक्ति 43: सॉकेट बंद करें।
• लाइन्स 18-45: ट्राइ -कैच ब्लॉक का उपयोग इस उदाहरण में किया जाता है क्योंकि प्रोग्राम कीबोर्ड से बाधित हो सकता है।
• लाइन्स 46-48: ओपन सॉकेट्स को बंद करने की आवश्यकता नहीं है क्योंकि प्रोग्राम समाप्त होने पर पायथन उन्हें बंद कर देता है। हालांकि, स्पष्ट समापन अच्छा अभ्यास है।

उदाहरण 3

कॉपी सोर्स | HTML कॉपी करें

1. आयात सॉकेट, का चयन करें
3. EOL1 = b '\ n \ n'
4. EOL2 = b '\ n \ r \ n'
5. प्रतिक्रिया = b 'एचटीटीपी / 1.0 200 ओके \ r \ n दिनांक: सोम, 1 जनवरी 1996 01:01:01 GMT \ r \'
6. प्रतिक्रिया + = b 'सामग्री-प्रकार: पाठ / सादा \ r \ n नियंत्रण-लंबाई: 13 \ r \ n \ r \ n'
7. प्रतिक्रिया + = b 'हैलो, दुनिया!'
9. serverocket = सॉकेट । सॉकेट ( सॉकेट .AF_INET, सॉकेट .SOCK_STREAM)
10. serverocket.setsockopt ( सॉकेट .SOL_SOCKET, सॉकेट .SO_REUSEADDR, 1
11. serverocket.bind (( '0.0.0.0' , 8080 ))
12. serverocket.listen ( 1 )
13. serverocket.setblocking ( 0 )
15. epoll = select .epoll ()
16. epoll.register (serverocket.fileno) (, .EPOLLIN) चुनें
18. कोशिश करें :
19. कनेक्शन = {}; अनुरोध = {}; प्रतिक्रियाएँ = {}
20. जबकि सच:
21. घटनाएँ = epoll.poll ( 1 )
22. fileno के लिए, घटनाओं में घटना:
23. अगर fileno == serverocket.fileno ():
24. कनेक्शन, पता = serverocket.accept ()
25. कनेक्शन.सेटब्लॉकिंग ( 0 )
26. epoll.register (connection.fileno) (, चुनें .EPOLLIN)
27. कनेक्शन [connection.fileno ()] = कनेक्शन
28. अनुरोध [कनेक्शन .fileno ()] = b ''
29. प्रतिक्रिया [कनेक्शन .fileno ()] = प्रतिक्रिया
30. एलीफ घटना और चुनें .EPOLLIN:
31. अनुरोध [fileno] + = कनेक्शन [fileno] .recv ( 1024 )
32. यदि अनुरोधों में EOL1 [fileno] या अनुरोधों में EOL2 [fileno]:
33. epoll.modify (फाइनेनो, सेलेक्ट .EPOLLOUT)
34. प्रिंट ( '-' * 40 + '\ n' + अनुरोध [फाइलो] .डॉस्कोप () [: - 2 ])
35. एलीफ घटना और चुनें .EPOLLOUT:
36. byteswritten = कनेक्शन [fileno]। एसेंड (प्रतिक्रियाएं [fileno])
37. प्रतिक्रियाओं [fileno] = प्रतिक्रियाओं [fileno] [बाइट्स लिखित:]
38. अगर लेन (प्रतिक्रिया [fileno]) == 0 :
39. epoll.modify (फ़िलिनो, 0 )
40. कनेक्शन [fileno]। शटडाउन ( सॉकेट .SHUT_RDWR)
41. एलीफ घटना और चयन .EPOLLHUP:
42. epoll.unregister (fileno)
43. कनेक्शन [fileno] .close ()
44. डेल कनेक्शन [फाइलो]
45. अंत में :
46. epoll.unregister (serverocket.fileno ())
47. epoll.close ()
48. serverocket.close ()

एपोल में ऑपरेशन के दो मोड हैं जिन्हें एज-ट्रिगर और लेवल-ट्रिगर कहा जाता है। एज-ट्रिगर मोड में, कॉल करना epoll.poll () केवल पढ़ने या लिखने की घटनाओं के बाद सॉकेट पर हुई घटनाओं को वापस करेगा। कॉलर को इस घटना से जुड़े सभी डेटा को संसाधित करना होगा, बिना कॉल किए बार-बार epoll.poll () में। जब किसी विशिष्ट ईवेंट का डेटा समाप्त हो जाता है, तो सॉकेट के साथ काम करने के लिए अतिरिक्त प्रयास अपवादों को जन्म देंगे। इसके विपरीत, स्तर-ट्रिगर मोड में, epoll.poll () को बार-बार कॉल करने से ब्याज की घटनाओं की बार-बार सूचना मिलेगी जब तक कि घटनाओं से जुड़े सभी डेटा को संसाधित नहीं किया गया हो। स्तर-ट्रिगर मोड में सामान्य ऑपरेशन के दौरान कोई अपवाद नहीं होता है।

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

उदाहरण 3 स्तर-ट्रिगर मोड का उपयोग करता है, जो डिफ़ॉल्ट मोड है। उदाहरण 4 दर्शाता है कि एज-ट्रिगर मोड का उपयोग कैसे करें। लाइन्स 25, 36, और 45 ऐसे चक्रों का परिचय देते हैं जो तब तक काम करते हैं जब तक कि कोई अपवाद नहीं होता (या यह ज्ञात हो जाता है कि सभी डेटा संसाधित हो चुके हैं)। लाइन्स 32, 38, और 48 कैच अपवाद हैं। अंत में, लाइनों 16, 28, 41, और 51 में एक EPOLLET मास्क जोड़ा जाता है, जो एज-ट्रिगर मोड सेट करता है।

उदाहरण 4

कॉपी सोर्स | HTML कॉपी करें

1. आयात सॉकेट, का चयन करें
3. EOL1 = b '\ n \ n'
4. EOL2 = b '\ n \ r \ n'
5. प्रतिक्रिया = b 'एचटीटीपी / 1.0 200 ओके \ r \ n दिनांक: सोम, 1 जनवरी 1996 01:01:01 GMT \ r \'
6. प्रतिक्रिया + = b 'सामग्री-प्रकार: पाठ / सादा \ r \ n नियंत्रण-लंबाई: 13 \ r \ n \ r \ n'
7. प्रतिक्रिया + = b 'हैलो, दुनिया!'
9. serverocket = सॉकेट । सॉकेट ( सॉकेट .AF_INET, सॉकेट .SOCK_STREAM)
10. serverocket.setsockopt ( सॉकेट .SOL_SOCKET, सॉकेट .SO_REUSEADDR, 1
11. serverocket.bind (( '0.0.0.0' , 8080 ))
12. serverocket.listen ( 1 )
13. serverocket.setblocking ( 0 )
15. epoll = select .epoll ()
16. epoll.register (serverocket.fileno) (, चुनें .EPOLLIN | select .EPOLLET)
18. कोशिश करें :
19. कनेक्शन = {}; अनुरोध = {}; प्रतिक्रियाएँ = {}
20. जबकि सच:
21. घटनाएँ = epoll.poll ( 1 )
22. fileno के लिए, घटनाओं में घटना:
23. अगर fileno == serverocket.fileno ():
24. कोशिश करें :
25. जबकि सच:
26. कनेक्शन, पता = serverocket.accept ()
27. कनेक्शन.सेटब्लॉकिंग ( 0 )
28. epoll.register (connection.fileno) (, select .EPOLLIN | select .EPOLLET)।
29. कनेक्शन [connection.fileno ()] = कनेक्शन
30. अनुरोध [कनेक्शन .fileno ()] = b ''
31. प्रतिक्रिया [कनेक्शन .fileno ()] = प्रतिक्रिया
32. सॉकेट को छोड़कर।
33. पास
34. एलीफ घटना और चुनें .EPOLLIN:
35. कोशिश करें :
36. जबकि सच:
37. अनुरोध [fileno] + = कनेक्शन [fileno] .recv ( 1024 )
38. सॉकेट को छोड़कर।
39. पास
40. यदि अनुरोधों में EOL1 [fileno] या अनुरोधों में EOL2 [fileno]:
41. epoll.modify (फाइनेनो, सेलेक्ट .EPOLLOUT | सिलेक्ट .EPOLLET)
42. प्रिंट ( '-' * 40 + '\ n' + अनुरोध [फाइलो] .डॉस्कोप () [: - 2 ])
43. एलीफ घटना और चुनें .EPOLLOUT:
44. कोशिश करें :
45. जबकि लेन (प्रतिक्रिया [fileno])> 0 :
46. byteswritten = कनेक्शन [fileno]। एसेंड (प्रतिक्रियाएं [fileno])
47. प्रतिक्रियाओं [fileno] = प्रतिक्रियाओं [fileno] [बाइट्स लिखित:]
48. सॉकेट को छोड़कर।
49. पास
50. अगर लेन (प्रतिक्रिया [fileno]) == 0 :
51. epoll.modify (फाइनेनो, सेलेक्ट .EPOLLET)
52. कनेक्शन [fileno]। शटडाउन ( सॉकेट .SHUT_RDWR)
53. एलीफ घटना और चयन .EPOLLHUP:
54. epoll.unregister (fileno)
55. कनेक्शन [fileno] .close ()
56. डेल कनेक्शन [फाइलो]
57. अंत में :
58. epoll.unregister (serverocket.fileno ())
59. epoll.close ()
60. serverocket.close ()

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

इन दो मोडों के अलावा, सॉकेट्स को EPOLLONESHOT ईवेंट में भी सब्सक्राइब किया जा सकता है। इस विकल्प का उपयोग करते समय, ईवेंट केवल एकल कॉल के लिए सही है epoll.poll (), जिसके बाद यह स्वचालित रूप से देखी गई घटनाओं की सूची से हटा दिया जाता है।

प्रदर्शन के मुद्दे

सर्वर कनेक्शन कतार की लंबाई

सभी उदाहरणों की 12 वीं पंक्ति में serverocket.listen () विधि के लिए कॉल दिखाया गया है। इस विधि के लिए पैरामीटर सर्वर कनेक्शन कतार की लंबाई है (बैकलॉग सुनो)। यह ऑपरेटिंग सिस्टम को टीसीपी / आईपी कनेक्शन की अधिकतम संख्या के बारे में बताता है जिसे पायनॉन प्रोग्राम द्वारा स्वीकार किए जाने से पहले सिस्टम कतार में रखा जा सकता है। हर बार जब एक सर्वर सॉकेट पर पायथन प्रोग्राम कॉल स्वीकार () करता है, तो कनेक्शन में से एक को कतार से हटा दिया जाता है और एक अन्य आने वाले कनेक्शन के लिए मुफ्त स्थान का उपयोग किया जा सकता है। जब कतार भर जाती है, तो नए आने वाले कनेक्शन को चुपचाप नजरअंदाज कर दिया जाता है, जिससे क्लाइंट की तरफ अनावश्यक देरी होती है। एक व्यस्त सर्वर आमतौर पर सैकड़ों और हजारों समवर्ती कनेक्शनों को संभालता है, इसलिए 1 का मूल्य अपर्याप्त होगा। एक उदाहरण के रूप में, जब एक साथ HTTP 1.0 क्लाइंट के सैकड़ों के साथ उपरोक्त उदाहरणों को लोड करने के लिए ab का उपयोग किया जाता है, तो 50 से कम की कतार की लंबाई कभी-कभी एक गंभीर प्रदर्शन ड्रॉप हो सकती है।

टीसीपी सेटिंग्स

TCP_CORK विकल्प तैयार होने तक डेटा भेजना (बोतल बंद) कर सकता है। उदाहरण 5 की लाइनों 34 और 40 में चित्रित यह विकल्प, HTTP / 1.1 पाइपलाइन का उपयोग करके HTTP सर्वर के लिए उपयोगी हो सकता है।

उदाहरण 5

कॉपी सोर्स | HTML कॉपी करें

1. आयात सॉकेट, का चयन करें
3. EOL1 = b '\ n \ n'
4. EOL2 = b '\ n \ r \ n'
5. प्रतिक्रिया = b 'एचटीटीपी / 1.0 200 ओके \ r \ n दिनांक: सोम, 1 जनवरी 1996 01:01:01 GMT \ r \'
6. प्रतिक्रिया + = b 'सामग्री-प्रकार: पाठ / सादा \ r \ n नियंत्रण-लंबाई: 13 \ r \ n \ r \ n'
7. प्रतिक्रिया + = b 'हैलो, दुनिया!'
9. serverocket = सॉकेट । सॉकेट ( सॉकेट .AF_INET, सॉकेट .SOCK_STREAM)
10. serverocket.setsockopt ( सॉकेट .SOL_SOCKET, सॉकेट .SO_REUSEADDR, 1
11. serverocket.bind (( '0.0.0.0' , 8080 ))
12. serverocket.listen ( 1 )
13. serverocket.setblocking ( 0 )
15. epoll = select .epoll ()
16. epoll.register (serverocket.fileno) (, .EPOLLIN) चुनें
18. कोशिश करें :
19. कनेक्शन = {}; अनुरोध = {}; प्रतिक्रियाएँ = {}
20. जबकि सच:
21. घटनाएँ = epoll.poll ( 1 )
22. fileno के लिए, घटनाओं में घटना:
23. अगर fileno == serverocket.fileno ():
24. कनेक्शन, पता = serverocket.accept ()
25. कनेक्शन.सेटब्लॉकिंग ( 0 )
26. epoll.register (connection.fileno) (, चुनें .EPOLLIN)
27. कनेक्शन [connection.fileno ()] = कनेक्शन
28. अनुरोध [कनेक्शन .fileno ()] = b ''
29. प्रतिक्रिया [कनेक्शन .fileno ()] = प्रतिक्रिया
30. एलीफ घटना और चुनें .EPOLLIN:
31. अनुरोध [fileno] + = कनेक्शन [fileno] .recv ( 1024 )
32. यदि अनुरोधों में EOL1 [fileno] या अनुरोधों में EOL2 [fileno]:
33. epoll.modify (फाइनेनो, सेलेक्ट .EPOLLOUT)
34. कनेक्शन [fileno] .setsockopt ( सॉकेट .IPPROTO_TCP, सॉकेट .TCP_CORK, 1 )
35. प्रिंट ( '-' * 40 + '\ n' + अनुरोध [फाइलो] .डॉस्कोप () [: - 2 ])
36. एलीफ घटना और चुनें .EPOLLOUT:
37. byteswritten = कनेक्शन [fileno]। एसेंड (प्रतिक्रियाएं [fileno])
38. प्रतिक्रियाओं [fileno] = प्रतिक्रियाओं [fileno] [बाइट्स लिखित:]
39. अगर लेन (प्रतिक्रिया [fileno]) == 0 :
40. कनेक्शन [fileno] .setsockopt ( सॉकेट .IPPROTO_TCP, सॉकेट .TCP_CORK, 0 )
41. epoll.modify (फ़िलिनो, 0 )
42. कनेक्शन [fileno]। शटडाउन ( सॉकेट .SHUT_RDWR)
43. एलीफ घटना और चयन .EPOLLHUP:
44. epoll.unregister (fileno)
45. कनेक्शन [fileno] .close ()
46. डेल कनेक्शन [फाइलो]
47. अंत में :
48. epoll.unregister (serverocket.fileno ())
49. epoll.close ()
50. serverocket.close ()

दूसरी ओर, TCP_NODELAY विकल्प सिस्टम को बताता है कि किसी भी डेटा को सॉकेट.सेंड () को भेजा जाए जो ऑपरेटिंग सिस्टम द्वारा बफरिंग किए बिना तुरंत क्लाइंट को भेजा जाए। उदाहरण 6 के लाइन 14 में दर्शाया गया यह विकल्प, SSH क्लाइंट और अन्य रियल-टाइम एप्लिकेशन के लिए उपयोगी हो सकता है।

उदाहरण 6

कॉपी सोर्स | HTML कॉपी करें

1. आयात सॉकेट, का चयन करें
3. EOL1 = b '\ n \ n'
4. EOL2 = b '\ n \ r \ n'
5. प्रतिक्रिया = b 'एचटीटीपी / 1.0 200 ओके \ r \ n दिनांक: सोम, 1 जनवरी 1996 01:01:01 GMT \ r \'
6. प्रतिक्रिया + = b 'सामग्री-प्रकार: पाठ / सादा \ r \ n नियंत्रण-लंबाई: 13 \ r \ n \ r \ n'
7. प्रतिक्रिया + = b 'हैलो, दुनिया!'
9. serverocket = सॉकेट । सॉकेट ( सॉकेट .AF_INET, सॉकेट .SOCK_STREAM)
10. serverocket.setsockopt ( सॉकेट .SOL_SOCKET, सॉकेट .SO_REUSEADDR, 1
11. serverocket.bind (( '0.0.0.0' , 8080 ))
12. serverocket.listen ( 1 )
13. serverocket.setblocking ( 0 )
14. serverocket.setsockopt ( सॉकेट .IPPROTO_TCP, सॉकेट .TCP_NODELAY, 1 )
16. epoll = select .epoll ()
17. epoll.register (serverocket.fileno) (, .EPOLLIN) चुनें
19. कोशिश करें :
20. कनेक्शन = {}; अनुरोध = {}; प्रतिक्रियाएँ = {}
21. जबकि सच:
22. घटनाएँ = epoll.poll ( 1 )
23. fileno के लिए, घटनाओं में घटना:
24. अगर fileno == serverocket.fileno ():
25. कनेक्शन, पता = serverocket.accept ()
26. कनेक्शन.सेटब्लॉकिंग ( 0 )
27. epoll.register (connection.fileno) (, चुनें .EPOLLIN)
28. कनेक्शन [connection.fileno ()] = कनेक्शन
29. अनुरोध [कनेक्शन .fileno ()] = b ''
30. प्रतिक्रिया [कनेक्शन .fileno ()] = प्रतिक्रिया
31. एलीफ घटना और चुनें .EPOLLIN:
32. अनुरोध [fileno] + = कनेक्शन [fileno] .recv ( 1024 )
33. यदि अनुरोधों में EOL1 [fileno] या अनुरोधों में EOL2 [fileno]:
34. epoll.modify (फाइनेनो, सेलेक्ट .EPOLLOUT)
35. प्रिंट ( '-' * 40 + '\ n' + अनुरोध [फाइलो] .डॉस्कोप () [: - 2 ])
36. एलीफ घटना और चुनें .EPOLLOUT:
37. byteswritten = कनेक्शन [fileno]। एसेंड (प्रतिक्रियाएं [fileno])
38. प्रतिक्रियाओं [fileno] = प्रतिक्रियाओं [fileno] [बाइट्स लिखित:]
39. अगर लेन (प्रतिक्रिया [fileno]) == 0 :
40. epoll.modify (फ़िलिनो, 0 )
41. कनेक्शन [fileno]। शटडाउन ( सॉकेट .SHUT_RDWR)
42. एलीफ घटना और चयन .EPOLLHUP:
43. epoll.unregister (fileno)
44. कनेक्शन [fileno] .close ()
45. डेल कनेक्शन [फाइलो]
46. अंत में :
47. epoll.unregister (serverocket.fileno ())
48. epoll.close ()
49. serverocket.close ()

स्रोत कोड

इस पृष्ठ के उदाहरण सार्वजनिक रूप से उपलब्ध हैं और इन्हें यहाँ डाउनलोड किया जा सकता है ।

अनुवादक से

जब कोई दूरस्थ क्लाइंट सॉकेट बंद करता है, तो EPOLLIN ईवेंट स्थानीय सॉकेट पर आता है , लेकिन VV पढ़ने पर कुछ भी प्राप्त नहीं होगा। तो पल

कॉपी सोर्स | HTML कॉपी करें
एलीफ घटना और चुनें .EPOLLIN:
कोशिश करें :
जबकि सच:
अनुरोध [fileno] + = कनेक्शन [fileno] .recv ( 1024 )

आप इस तरह लिख सकते हैं:

कॉपी सोर्स | HTML कॉपी करें
एलीफ घटना और चुनें .EPOLLIN:
कोशिश करें :
जबकि सच:
डेटा = कनेक्शन [fileno] .recv ( 1024 )
यदि डेटा नहीं है:
epoll.modify (फाइनेनो, सेलेक्ट .EPOLLET)
कनेक्शन [fileno]। शटडाउन ( सॉकेट .SHUT_RDWR)
और :
अनुरोध [फाइलो] + = डेटा

इस मामले में कनेक्शन टूट जाने पर कोई लूपिंग नहीं होगी। मैं एक ऐसे कोड से मिला, जहां अंतर तुरंत नहीं होता है, लेकिन एक गलत निर्धारण की संभावना को बाहर करने के लिए कई लगातार ऐसी बेकार यात्राओं के बाद।