启动和停止 Twisted 连接

Question

我正在编写使用 python Twisted API 的应用程序（即WebSocketClientProtocol, WebSocketClientFactory, ReconnectiongClientFactory。我想用以下接口将客户端工厂包装到阅读器中

class Reader: 
    def start(self):
        pass
    def stop(self):
        pass

Start 函数将用于打开连接（即在 ws api 上连接并开始读取数据），而stop 将停止此类连接。

我的问题是，如果我在 start 中使用 reactor.run()，连接就会开始并且一切正常，但我的代码永远不会通过该行（看起来像阻止对我的调用）并且我无法执行后续行（包括 @ 987654326@ 在我的测试中）。

我尝试过使用诸如reactor.callFromThread(reactor.run) 和reactor.callFromThread(reactor.stop) 之类的变体，甚至是调用Thread(target=...) 的excplicity，但似乎都不起作用（它们通常根本不构建协议或打开连接）。

欢迎任何有关如何实施 Reader.start 和 Reader.stop 的帮助或指南。

Answer 1

如果您将reactor.run 放在Reader.start 中，那么Reader 将是一个难以与其他代码一起使用的组件。您的困难只是这方面的第一个症状。

调用reactor.run 和reactor.stop 是负责管理应用程序生命周期的代码的工作。将这些调用与您的 WebSocket 应用程序代码分开放置。例如：

r = Reader()
r.start()
reactor.run()

或者更好的是，实现 a twist(d) plugin 并让 twist(d) 为您管理反应器。