कुछ भी अवरुद्ध किए बिना, अजगर में एक वर्ग के भीतर asyncore को कैसे संभालें?

Question

मुझे ऐसी कक्षा बनाने की आवश्यकता है जो एसएमटीपी संदेशों को प्राप्त और स्टोर कर सके, यानी ई-मेल। ऐसा करने के लिए, here पोस्ट किए गए उदाहरण के अनुसार, मैं asyncore का उपयोग कर रहा हूं। हालांकि, asyncore.loop() अवरुद्ध है इसलिए मैं कोड में और कुछ नहीं कर सकता।

तो मैंने धागे का उपयोग करने के बारे में सोचा। यहाँ एक उदाहरण-कोड पता चलता है कि मेरे मन में है:

class MyServer(smtpd.SMTPServer): 
    # derive from the python server class 

    def process_message(..): 
     # overwrite a smtpd.SMTPServer method to be able to handle the received messages 
     ... 
     self.list_emails.append(this_email) 

    def get_number_received_emails(self): 
     """Return the current number of stored emails""" 
     return len(self.list_emails) 


    def start_receiving(self): 
     """Start the actual server to listen on port 25""" 

     self.thread = threading.Thread(target=asyncore.loop) 
     self.thread.start()  

    def stop(self): 
     """Stop listening now to port 25""" 
     # close the SMTPserver from itself 
     self.close() 
     self.thread.join() 

मुझे आशा है कि आप चित्र मिलता है। कक्षा MyServer गैर-अवरुद्ध तरीके से बंदरगाह 25 को सुनने और बंद करने में सक्षम होना चाहिए, सुनने के दौरान संदेशों के लिए पूछताछ करने में सक्षम होना चाहिए (या नहीं)। start विधि asyncore.loop() श्रोता शुरू करती है, जो, जब कोई ईमेल प्राप्त होता है, तो आंतरिक सूची में शामिल होता है। इसी तरह, stop विधि इस सर्वर को रोकने में सक्षम होना चाहिए, जैसा कि here सुझाया गया है।

तथ्य के रूप में मैं उम्मीद इस कोड काम नहीं करता है के बावजूद करने के लिए (asyncore हमेशा के लिए चलाने के लिए मैं भी ऊपर stop विधि कॉल लगता है,। error मैं बढ़ा stop भीतर catched है, लेकिन asyncore.loop() युक्त target समारोह के भीतर नहीं), मुझे यकीन नहीं है कि समस्या का मेरा दृष्टिकोण समझदार है या नहीं। उपर्युक्त कोड को ठीक करने या तीसरे पक्ष के सॉफ़्टवेयर का उपयोग करके के बिना अधिक ठोस कार्यान्वयन () का प्रस्ताव देने के लिए कोई सुझाव, की सराहना की जाती है।

Answer 1

प्रदान किया गया समाधान सबसे परिष्कृत समाधान नहीं हो सकता है, लेकिन यह उचित काम करता है और परीक्षण किया गया है।

सबसे पहले, asyncore.loop() साथ बात है कि यह सब asyncore चैनलों तक ब्लॉक उपयोगकर्ता Wessie से पहले एक टिप्पणी में कहा के रूप में बंद हो जाती हैं, है। smtp example का जिक्र करते हुए, यह पता चला है कि smtpd.SMTPServerasyncore.dispatcher से प्राप्त होता है (जैसा कि smtpd documentation पर वर्णित है), जो कि किस चैनल को बंद करने के सवाल का उत्तर देता है।

इसलिए, मूल प्रश्न निम्नलिखित अद्यतन उदाहरण कोड के साथ उत्तर दिया जा सकता है:

class CustomSMTPServer(smtpd.SMTPServer): 
    # store the emails in any form inside the custom SMTP server 
    emails = [] 
    # overwrite the method that is used to process the received 
    # emails, putting them into self.emails for example 
    def process_message(self, peer, mailfrom, rcpttos, data): 
     # email processing 


class MyReceiver(object): 
    def start(self): 
     """Start the listening service""" 
     # here I create an instance of the SMTP server, derived from asyncore.dispatcher 
     self.smtp = CustomSMTPServer(('0.0.0.0', 25), None) 
     # and here I also start the asyncore loop, listening for SMTP connection, within a thread 
     # timeout parameter is important, otherwise code will block 30 seconds after the smtp channel has been closed 
     self.thread = threading.Thread(target=asyncore.loop,kwargs = {'timeout':1}) 
     self.thread.start()  

    def stop(self): 
     """Stop listening now to port 25""" 
     # close the SMTPserver to ensure no channels connect to asyncore 
     self.smtp.close() 
     # now it is save to wait for the thread to finish, i.e. for asyncore.loop() to exit 
     self.thread.join() 

    # now it finally it is possible to use an instance of this class to check for emails or whatever in a non-blocking way 
    def count(self): 
     """Return the number of emails received""" 
     return len(self.smtp.emails)   
    def get(self): 
     """Return all emails received so far""" 
     return self.smtp.emails 
    .... 

अंत में

तो, मैं शुरू करने और पोर्ट 25 पर सुन एक गैर भीतर रोकने के लिए एक start और एक stop विधि है पर्यावरण को अवरुद्ध करना

Answer 2

आपको इसके बजाय ट्विस्ट का उपयोग करने पर विचार करना चाहिए। http://twistedmatrix.com/trac/browser/trunk/doc/mail/examples/emailserver.tac दर्शाता है कि एक अनुकूलन योग्य ऑन-डिलीवरी हुक के साथ एक एसएमटीपी सर्वर कैसे स्थापित करें।

Answer 3

अन्य प्रश्न asyncore.loop doesn't terminate when there are no more connections

मुझे लगता है कि आप सूत्रण सोच से थोड़ा हैं से आ रहा है।

import threading 

loop_thread = threading.Thread(target=asyncore.loop, name="Asyncore Loop") 
# If you want to make the thread a daemon 
# loop_thread.daemon = True 
loop_thread.start() 

यह एक नया सूत्र में यह चलेंगे और जब तक सब asyncore चैनलों बंद हो जाती हैं चलती रहेगी: अन्य सवाल से कोड का उपयोग करना, आप एक नया धागा है कि निम्नलिखित कोड का टुकड़ा द्वारा asyncore.loop चलाता है शुरू कर सकते हैं।