如何从AutobahnPython中的ApplicationRunner获取反应堆

How to get the reactor from ApplicationRunner in autobahnPython(如何从AutobahnPython中的ApplicationRunner获取反应堆)

问题描述

我有一个Autobahn客户端，它使用Autobahn中的ApplicationRunner类连接到WAMP路由器(Crosbar)。在主要部分中，它按如下方式附加了我的ApplicationSession类"Rescheduler"：

if __name__ == '__main__':
    from autobahn.twisted.wamp import ApplicationRunner

    runner = ApplicationRunner(url=u"ws://localhost:8080/ws", realm=u"RE_acct")

    runner.run(REScheduler, start_reactor=True, auto_reconnect=True)

现在，我还需要应用程序运行器启动的反应器用于其他目的。例如，调用一些reactor.callLater(...)。 我怎么才能进入这个反应堆。我在文档中没有找到任何内容。

推荐答案

Twisted(遗憾的是)使用(进程)全局反应器对象。这意味着，一旦选择了反应器(如果设置start_reactor=True，ApplicationRunner就会这样做)，只需在代码中需要它的位置from twisted.internet import reactor执行from twisted.internet import reactor。