2

这与此处先前回答的问题有关：使用 Twisted 记录 SMTP 连接。我有一个在每个 ConsoleMessageDelivery 实例中创建的数据库资源，我需要确保在关闭套接字时清理它。我有一个名为 DenyFactory 的 WrappingFactory ，并且在关闭套接字时调用了 DenyFactory.unregisterProtocol 方法，但是我无法（我可以弄清楚）如何访问在被销毁的 ConsoleMessageDelivery 实例中创建的资源。我在 ConsoleMessageDelivery 中尝试了del () 方法，但从未调用过。在这种情况下清理资源的最佳方法是什么？

class ConsoleMessageDelivery:
    implements(smtp.IMessageDelivery)

    def receivedHeader(self, helo, origin, recipients):
        myHostname, clientIP = helo
        headerValue = "by %s from %s with ESMTP ; %s" % (myHostname, clientIP, smtp.rfc822date())
        # email.Header.Header used for automatic wrapping of long lines
        return "Received: %s" % Header(headerValue)

    def validateFrom(self, helo, origin):
        # All addresses are accepted
        return origin

    def validateTo(self, user):
        if user.dest.local == "console":
            return lambda: ConsoleMessage()
        raise smtp.SMTPBadRcpt(user)

class ConsoleMessage:
    implements(smtp.IMessage)

    def __init__(self):
        self.lines = []

    def lineReceived(self, line):
        self.lines.append(line)

    def eomReceived(self):
        return defer.succeed(None)

    def connectionLost(self):
        # There was an error, throw away the stored lines
        self.lines = None

class ConsoleSMTPFactory(smtp.SMTPFactory):
    protocol = smtp.ESMTP

    def __init__(self, *a, **kw):
        smtp.SMTPFactory.__init__(self, *a, **kw)
        self.delivery = ConsoleMessageDelivery()

    def buildProtocol(self, addr):
        p = smtp.SMTPFactory.buildProtocol(self, addr)
        p.delivery = self.delivery
        return p

class DenyFactory(WrappingFactory):

    def buildProtocol(self, clientAddress):
        if clientAddress.host == '1.3.3.7':
            # Reject it
            return None
        # Accept everything else
        return WrappingFactory.buildProtocol(self, clientAddress)

    def unregisterProtocol(self, p):
        print "Unregister called"
4

1 回答 1

3

首先，永远不要使用__del__，特别是如果您有一些要清理的资源。 __del__防止在引用周期中对对象进行垃圾收集。（或者，切换到 PyPy，它可以通过对循环中的对象集合施加任意顺序来收集此类对象。）

接下来，考虑在消息传递工厂中打开您的数据库连接（或启动一个连接池）并在所有消息传递对象之间共享它。这样你就不需要清理它们的连接，因为你会在以后的消息中重复使用它们，而且你不会为每条消息分配一个新的，所以没有泄漏。

eomReceived最后，如果您真的需要任何每个事务的对象，您可以在您的或对象的connectionLost实现中清理它们IMessage。一旦 SMTP 事务的 DATA 部分完成（因为接收到所有数据或因为连接丢失），将调用其中一种方法。请注意，因为 SMTP 支持在单个事务中将消息传递给多个收件人，所以可能有多个IMessage对象参与，即使只有一个IMessageDelivery对象。因此，您可能希望保留一个计数器 -validateTo将消息传递对象上成功调用的调用次数与消息对象上的eomReceived/connectionLost调用次数相匹配。当每个调用发生相同数量的调用时，事务就完成了。

于 2012-08-31T11:46:14.897 回答