Làm thế nào để xử lý asyncore trong một lớp trong python, mà không chặn bất cứ điều gì?

Question

Tôi cần tạo một lớp có thể nhận và lưu trữ tin nhắn SMTP, tức là E-Mail. Để làm như vậy, tôi đang sử dụng asyncore theo một ví dụ được đăng here. Tuy nhiên, asyncore.loop() đang chặn vì vậy tôi không thể làm bất kỳ điều gì khác trong mã.

Vì vậy, tôi đã nghĩ đến việc sử dụng chuỗi. Dưới đây là một ví dụ-mã cho thấy những gì tôi có trong tâm trí:

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() 

Tôi hy vọng bạn sẽ có được hình ảnh. Lớp học MyServer sẽ có thể bắt đầu và dừng nghe cổng 25 theo cách không chặn, có thể truy vấn tin nhắn trong khi nghe (hoặc không). Phương thức start bắt đầu trình nghe asyncore.loop(), trong đó, khi nhận được email, hãy thêm vào danh sách nội bộ. Tương tự, phương pháp stop sẽ có thể dừng máy chủ này, như được đề xuất here.

Mặc dù thực tế mã này không hoạt động như tôi mong đợi để (asyncore có vẻ chạy mãi mãi, thậm chí tôi gọi là stop phương pháp trên. Các error tôi nâng cao được đánh bắt trong stop, nhưng không phải trong target hàm chứa asyncore.loop()), Tôi không chắc liệu cách tiếp cận của tôi đối với vấn đề có hiệu quả hay không. Bất kỳ đề xuất nào để sửa mã trên hoặc đề xuất triển khai vững chắc hơn (mà không cần sử dụng phần mềm của bên thứ ba), được đánh giá cao.

Answer 1

Giải pháp được cung cấp có thể không phải là giải pháp phức tạp nhất, nhưng nó hoạt động hợp lý và đã được thử nghiệm.

Trước hết, vấn đề với asyncore.loop() là nó chặn cho đến khi tất cả asyncore kênh bị đóng, vì người dùng Wessie được chỉ ra trong nhận xét trước đó. Đề cập đến số smtp example được đề cập trước đó, nó chỉ ra rằng smtpd.SMTPServer kế thừa từ asyncore.dispatcher (như được mô tả trên smtpd documentation), trả lời câu hỏi về kênh sẽ bị đóng.

Vì vậy, câu hỏi ban đầu có thể được giải đáp như sau ví dụ mã Cập nhật:

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 
    .... 

Vì vậy, cuối cùng, tôi có một và một phương pháp startstop để bắt đầu và dừng lại lắng nghe trên cổng 25 trong một tổ chức phi - môi trường khóa.

Answer 2

Bạn nên cân nhắc sử dụng Twisted. http://twistedmatrix.com/trac/browser/trunk/doc/mail/examples/emailserver.tac minh họa cách thiết lập máy chủ SMTP bằng móc có thể tùy chỉnh được.

Answer 3

Xuất phát từ câu hỏi khác asyncore.loop doesn't terminate when there are no more connections

Tôi nghĩ bạn hơi suy nghĩ về luồng. Sử dụng mã từ câu hỏi khác, bạn có thể bắt đầu một chủ đề mới mà chạy asyncore.loop bằng đoạn mã sau:

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() 

này sẽ chạy nó trong một chủ đề mới và sẽ tiếp tục đi cho đến khi tất cả asyncore kênh được đóng lại.