扭曲處理ConnectionLost異常

Question

我無法處理ConnectionLost異常。 我有什麼簡單的例子。首先，設置連接到Jabber服務器並ping它。我爲此使用了wokkel庫。然後我將errback添加到發送ping的方法中。在errback中，我處理ConnectionLost錯誤。之後，我關閉了互聯網連接。但是我看不到ConnectionLost是否被處理。我在我的應用程序中關閉連接，並調用所有異常處理程序。

平安順利。

[XmlStream,client] Ping to JID(u'jabber.ru') started at HivemindPingClientProtocol 
[-] SEND: «iq to='jabber.ru' type='get' id='H_3'>/>» 
[XmlStream,client] RECV: "/><feature-not-implemented xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>" 

互聯網連接被關閉

[-] SEND: «iq to='jabber.ru' type='get' id='H_6'>/>» 
[-] SEND: «iq to='jabber.ru' type='get' id='H_7'>/>» 

ConnectionLost的處理程序不被調用。 「流收於HivemindXMPPClient」被印刷在StreamManager在_disconnected方法

[-] Protocol stopped 
[-] Protocol closed 
[-] Transport stopped 
[XmlStream,client] Stream closed at HivemindXMPPClient 

所有的異常關閉流之後被處理。

[XmlStream,client] Failure [Failure instance: Traceback (failure with no frames): <class 'twisted.internet.error.ConnectionLost'>: Connection to the other side was lost in a non-clean fashion. 
[XmlStream,client] Failure [Failure instance: Traceback (failure with no frames): <class 'twisted.internet.error.ConnectionLost'>: Connection to the other side was lost in a non-clean fashion.] 
[XmlStream,client] Connection lost with [Failure instance: Traceback (failure with no frames): <class 'twisted.internet.error.ConnectionDone'>: Connection was closed cleanly.] 
[XmlStream,client] Stopping factory <hivemind.network.network_core.HivemindXmlStreamFactory object at 0xa2e904c>> 

任何人都可以解釋爲什麼關閉流後調用errbacks？其實我想實現一個重新連接功能（我已經使用重新連接工廠，但它不會對ConnectionLost做出反應）。有人能給我一些扭曲的重新連接實現的例子嗎？

腳本示例。 運行此腳本（確保ping工作正常）。然後關閉你的互聯網連接。當幾次ping發生時，您需要終止腳本。如您所見，ConnectionLost錯誤在關閉連接後處理。

import sys 
from twisted.python import log 
from twisted.words.protocols import jabber 
from twisted.internet.error import ConnectionLost 
from wokkel.client import XMPPClient 
from wokkel.ping import PingClientProtocol 
from twisted.internet.task import LoopingCall 

JID = unicode('YOUR@JABBER.ID') 
PASSWORD = 'PASSWORD' 
INTERVAL = 3 

class SpecialPingClientProtocol(PingClientProtocol): 

    def __init__(self, entity, interval): 
     self.__entity = jabber.jid.internJID(entity) 
     self.__interval = interval 
     self.__pingLoop = None 

    def _onError(self, failure): 
     log.msg('Failure %s at %s' % (failure, self.__class__.__name__)) 
     error = failure.trap(jabber.error.StanzaError, ConnectionLost) 
     if error == jabber.error.StanzaError: 
      if failure.value.condition == 'feature-not-implemented': 
       return None 
     elif error == ConnectionLost: 
      # Do some beautiful things 
      log.msg('Connection is lost. I want to reconnect NOW') 
     return failure 

    def _sendPing(self): 
     defer = self.ping(self.__entity) 
     defer.addErrback(self._onError) 

    def stopPing(self): 
     log.msg('Ping to %s stopped at %s' % (self.__entity, self.__class__.__name__)) 
     if self.__pingLoop is not None and self.__pingLoop.running: 
      self.__pingLoop.stop() 
      self.__pingLoop = None 

    def startPing(self): 
     log.msg('Ping to %s started at %s ' % (self.__entity, self.__class__.__name__)) 
     self.__pingLoop = LoopingCall(self._sendPing) 
     self.__pingLoop.start(self.__interval, now = False) 

def main(): 
    log.startLogging(sys.stdout) 
    transport = XMPPClient(jabber.jid.internJID(JID), PASSWORD) 
    transport.logTraffic = True 
    pinger = SpecialPingClientProtocol(JID, INTERVAL) 
    pinger.setHandlerParent(transport) 
    transport.startService() 
    pinger.startPing() 
    reactor.run() 

if __name__ == '__main__': 
    from twisted.internet import reactor 
    main() 

Answer 1

協議有：

clientConnectionFailed(self, connector, reason) 
clientConnectionLost(self, connector, reason) 

可以同時覆蓋和通話 PingClientProtocol.clientConnectionFailed 和PingClientProtocol.clientConnectionLost

假設PingClientProtocol從某種程度上協議繼承