基本的aiosmtpd SMTP服务器示例

Question

如何将以下使用smtpd的基本SMTP服务器转换为使用aiosmtpd的服务器？

import smtpd

class CustomSMTPServer(smtpd.SMTPServer):

    def process_message(self, peer, mailfrom, rcpttos, data):
        myqueue.queue.put(data)

self.server = CustomSMTPServer(('127.0.0.1', 10025), None)

Answer 1

要将CustomSMTPServer转换为使用aiosmtpd的东西，您必须使用与process_message()方法相同的handle_DATA()方法定义处理程序类：

import aiosmtpd.controller

class CustomSMTPHandler:
    async def handle_DATA(self, server, session, envelope):
        myqueue.queue.put(envelope.content)
        return '250 OK'

handler = CustomSMTPHandler()
self.server = aiosmtpd.controller.Controller(handler)
self.server.start()
input("Server started. Press Return to quit.")
self.server.stop()

请注意，handle_DATA()返回“250OK”，它告诉SMTP客户端消息已被成功接收和处理。与smtpd不同，使用aiosmtpd时，需要在handle_DATA()中返回SMTP响应代码。

注意，handle_DATA()必须是一个coroutine函数，也就是说，使用async def定义。如果您需要与Python3.4兼容，请在@asyncio.coroutine上使用handle_DATA()装饰器。

还请注意，self.server.start()在单独的线程中运行SMTP服务器，与接管当前线程的asyncore.loop()不同。

如果您需要访问peer、mailfrom或rcpttos，则它们可以分别作为session.peer、envelope.mail_from和envelope.rcpt_tos使用。