我如何设计一个扭曲的工厂来处理断开？

Question

我在一个模块中有一个重新连接的clientfactory。我希望模块尽可能灵活。我只需要一个TCP连接。我使用工厂作为这个连接的持久接口。在过去，工厂通过无休止地重试连接来响应断开连接，从不通知顶层脚本（导入模块的脚本）存在连接问题。在

下面是一个简单的例子：

Factory(protocol.ReconnectingClientFactory):

    def clientConnectionFailed(self, connector, reason):
        ...

    def clientConnectionLost(self, connector, reason):
        ...

我认为最好是在出现连接问题时通知顶层脚本（导入模块的脚本）。这样，顶层脚本可以定义断开连接解析行为，而不是在模块中硬编码。但是，将连接问题与顶级脚本通信的最佳方式是什么？在

我可以提出一个例外，但它会在哪里被抓住？我想反应堆会抓住它，但这又有什么帮助呢？在

我没有可以触发的回调或errback来通知top脚本连接问题。在

top脚本可以提供特定函数[作为参数]，以便在发生连接问题时调用。这个设计好吗？在

Answer 1

这个问题太抽象了，不能直接回答。这取决于你的顶层模块在做什么。在

但是，您应该考虑使用endpoints，而不是ClientFactory。这可能会解决一些设计问题。接收连接丢失通知有点麻烦（因为ClientFactory.clientConnectionLost实际上是IProtocol.connectionLost的重复通知，它不再存在于endpoints API中；因此，如果您关心这个问题，您必须包装IProtocol对象），但它确实允许您使用更通用的机制来重试失败的连接，而不是clientConnectionFailed，您只需在从connect返回的Deferred上得到一个错误。因此，例如，如果您只想“继续重新连接，直到成功”，您可以使用这个完全通用的Deferred-retry循环，而不是像ReconnectingClientFactory这样的特定连接：

# Warning, untested, sorry if it's broken.
@inlineCallbacks
def retry(deferredThing, delay=30.0, retryCount=5):
    retries = retryCount
    while True:
        try:
            result = yield deferredThing()
        except:
            if not retries:
                raise
            retries -= 1
            log.err()
            yield deferLater(reactor, delay, lambda : None)
        else:
            returnValue(result)

类似地，如果您可以使deferredThing函数返回一个Deferred，该函数除了调用IStreamServerEndpoint.connect之外，只会在协议的应用逻辑完成时触发，并监视connectionLost，如果在有趣的逻辑完成之前连接丢失，则会失败。在

Deferreds可以是跨系统多个级别管理这种异步重试状态的有效方法。在