2

これは、以前に回答された次の質問に関連しています: Logging SMTP connections with Twisted。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 は 1 回のトランザクションで複数の受信者へのメッセージの配信をサポートするため、オブジェクトが 1 つIMessageしかない場合でも、複数のオブジェクトが参加する可能性があることに注意してくださいIMessageDelivery。したがって、カウンターを保持したい場合があります-validateToメッセージ配信オブジェクトの呼び出しの成功数とメッセージオブジェクトのeomReceived/connectionLost呼び出しの数を一致させます。それぞれの呼び出しが同じ回数発生すると、トランザクションが完了します。

于 2012-08-31T11:46:14.897 に答える