Python 多线程 SMTP 代理

Question

我做了一个由多个smtpd实例组成的SMTP代理。SMTPServer 在 5 个不同的端口上运行，在负载平衡设置中接收、解析和重新注入 Postfix 中的电子邮件。

一切正常，但我无法在单独的线程上运行每个实例。 我想在解析和传递单个邮件之间等待大约 30/40 秒(以进一步处理它们(，但如果我输入 time.sleep，所有实例都会被阻止。

我想切换到并行处理而不是顺序处理，为了有 5 个并发处理线程，这是我的单线程代码的骨架：

class My_Proxy(smtpd.SMTPServer):
def process_message(self, peer, mailfrom, rcpttos, data, decode_data=True):
###PARSING AND PROCESSING STUFF...
time.sleep( 30 ) ###BLOCKING SLEEP
###SEND TO FINAL MTA
server.sendmail(mailfrom, rcpttos, data_rewrite_https)
server.quit()
#FIVE INSTANCES DIFFERENT PORTS
server1 = My_Proxy(('127.0.0.1', 10027), None)
server2 = My_Proxy(('127.0.0.1', 10029), None)
server3 = My_Proxy(('127.0.0.1', 10031), None)
server4 = My_Proxy(('127.0.0.1', 10033), None)
server5 = My_Proxy(('127.0.0.1', 10035), None)
asyncore.loop()

Answer 1

已解决。 对于任何最终遇到同样麻烦的人：如果你想要多线程，那么你需要切换到基于 asyncio 的 aiosmtpd，然后能够并行处理邮件。

Smtpd asyncore 循环只是保持顺序运行，所以 time.sleep(( 将休眠整个处理过程而不是单个邮件。

到目前为止，唯一的坏处是对邮件内容的更复杂的管理。在 smtpd 透明管理正文、编码、附件的地方，使用 aiosmtpd 需要单独解析信封部分和编码。