用扭曲连接两次 - 如何正确执行？

Question

我想使用twisted（和StarPy，它是asterisk ami的协议实现）连接到asterisk服务器。应用程序在那里启动传出传真。我发现了一些关于我的问题的提示，但我不知道如何正确处理这个问题。

第一份传真已正确发送。

问题是，如果我调用twisted 第二次，应用程序保留 挂在主循环中。

我知道我可能不会像这里这样做：

from starpy import manager
from twisted.internet import reactor

def main():
    f = manager.AMIFactory(cUser, cPass)
    print "Login"
    df = f.login(cServer, cPort)

    def onLogin(protocol):
        print "Logoff again"
        df = protocol.logoff()

        def onLogoff( result ):
            print "Logoff erfolgt"
            reactor.stop()

        return df.addCallbacks( onLogoff, onLogoff )

    def onFailure( reason ):
        print "Login failed"
        print reason.getTraceback()

    df.addCallbacks( onLogin, onFailure )
    return df

if __name__ == "__main__":
    reactor.callWhenRunning( main )
    reactor.run(installSignalHandlers=0)
    print "runned the first time"

    reactor.callWhenRunning( main )
    reactor.run(installSignalHandlers=0)
    print "will never reach this point"

我简化了代码 - 它除了再次登录+注销之外什么也不做。它永远不会从第二个reactor.run()调用中返回。

如何正确完成此操作？我被困在这里 - 提前谢谢。

此致， 弗洛里安.

Answer 1

正如 iny 所说，您只需调用一次reactor.run 和reactor.stop 即可完成所有操作。

如果我们考虑您发布的示例代码，我们会看到它需要执行以下步骤：

1. 启动反应器
2. 连接，发送传真，断开连接
3. 停止反应器
4. 启动反应器
5. 连接，发送传真，断开连接
6. 停止反应器

如果我们只删除步骤 3 和4、那么程序实际上会做一件相当合理的事情。

以下是您实现步骤 3 的方式：

def onLogoff( result ):
    print "Logoff erfolgt"
    reactor.stop()

这导致对 reactor.run 的第一次调用返回，为您实现步骤 4 扫清了道路：

reactor.callWhenRunning( main )
reactor.run(installSignalHandlers=0)

因此，这里的总体思路是直接跳到步骤 5，而不是执行步骤 3 和 4。考虑一下，如果您像这样重新定义 onLogoff

def onLogoff( result ):
    print "Logoff erfolgt"
    main()

并删除示例的最后三行，可能会发生什么情况。这实际上会给您带来无限循环，因为相同的 onLogoff 在第二次断开连接后运行并启动第三次连接。但是，您可以使用 main 函数的参数来控制重新启动行为来解决此问题。

一旦这有意义，您可能需要考虑将重试注销从 main 函数移到 __main__ 块中定义的回调中。这是 Deferreds 强大功能的一个重要部分：它使您可以在事件源（在本例中为传真发送函数）的实现和处理结果事件的代码（发送第二个传真，或退出，在这种情况下）。

Answer 2

感谢您的回答，我现在还没有实施解决方案，但我知道现在该怎么做......

这里是我学到的东西的简短总结。

首先，简而言之 - 我在使用twisted时遇到的问题：

1. 我不了解twisted的异步基础知识。我在图形用户界面框架中使用了类似的东西，但很长一段时间没有看到好处。
2. 其次，我尝试考虑多次同步调用事件循环。在我看来，这是必要的，因为我一次不能使用多于一根传出传真线路。因为twisted的事件循环是不可重启的，所以这是没有选择的。正如我在文档中读到的那样，“deferToThread”可以在这里帮助我，但我认为这不是最好的解决方案。

在我的概念中，我解决了这些问题：

• 使用 defer.DeferredSemaphore() 它允许我将并发限制为 1。
  我在这里找到了一个示例：http://oubiwann。 blogspot.com/2008/06/async-batching-with-twisted-walkthrough.html
• 任意调用twisted并让Defered完成工作（发送传真）
• 将传真状态写入数据库并发送收据邮件是从 deferreds 中调用的，

我需要大量的重新思考，但一旦你得到它，它看起来就很容易了。

感谢 iny 和 Jean-Paul Calderone 的帮助。

Answer 3

你无法重新启动反应堆。换句话说，您只能调用reactor.run()一次。

相反，可以在一个反应​​堆运行中完成您需要的一切。

Answer 4

如果您仍在寻找解决方案...我也遇到了同样的问题。我有一个使用 Twisted 在远程服务器上执行程序的脚本。我需要一种从 django 应用程序内同步运行该脚本的方法。我最终做的是让我的 Twisted 脚本调用远程服务器并打印到标准输出。然后，在我的 Django 应用程序中，我通过 subprocess.Popen 执行该脚本并设置 stdout=PIPE，这样我就可以捕获 Twisted 脚本的输出并在我的 Django 应用程序中使用它。

这并不是很理想，而且几乎违背了 Twisted 的目的，但这已经超越了“无法再次调用reactor.run()，因为 Twisted 脚本每次都在它自己的进程中运行。

这确实做到了最终对我来说效果很好，听起来与您所处的情况非常相似。我希望这会有所帮助（如果您认为有帮助，我可以发布一些代码示例，请告诉我）。