gpt4 book ai didi

python - 我如何设计一个扭曲的工厂来处理断开连接?

转载 作者:太空狗 更新时间:2023-10-30 01:24:11 25 4
gpt4 key购买 nike

我在模块中有一个 ReconnectingClientFactory。我希望模块尽可能灵活。我只需要一个 TCP 连接。我将工厂用作此连接的持久接口(interface)。过去,工厂会通过无休止地重试连接来响应断开连接,从不通知顶级脚本(导入模块的脚本)存在连接问题。

这是我所拥有的一个简短示例:

Factory(protocol.ReconnectingClientFactory):

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

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

我认为最好是在出现连接问题时通知顶层脚本(导入模块的脚本)。通过这种方式,顶级脚本可以定义断开连接解决方​​案行为,而不是将其全部硬编码在模块中。但是,将连接问题传达给顶级脚本的最佳方式是什么?

我可以提出异常,但它会在哪里被捕获?我猜 react 堆会捕捉到它,但这有什么帮助?

我无法触发回调或错误反馈来通知顶级脚本连接问题。

顶级脚本可以提供特定的函数[作为参数],以便在出现连接问题时调用。这是好的设计吗?

最佳答案

这个问题有点太抽象了,无法提供直接的答案。这取决于您的顶级模块在做什么。

但是,您应该考虑使用 endpoints ,而不是 ClientFactory。这可能会解决您的一些设计问题。接收连接丢失通知有点麻烦(因为 ClientFactory.clientConnectionLost 实际上是 IProtocol.connectionLost 的重复通知,它不再存在于端点 API 中;因此您必须包装 IProtocol 对象(如果您关心的话),但它确实允许您使用更通用的机制来重试失败 连接,而不是 clientConnectionFailed,您只需在从 connect 返回的 Deferred 上得到一个错误返回。因此,例如,如果您想做的只是“继续重新连接直到成功”,您可以使用这个完全通用的 Deferred-retry-loop 而不是像 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,它只会在您的协议(protocol)的应用程序逻辑完成时触发,除了调用 IStreamServerEndpoint。 connect,监视 connectionLost,如果在有趣的逻辑完成之前连接丢失,将会失败。

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

关于python - 我如何设计一个扭曲的工厂来处理断开连接?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5447020/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com