如何在 Twisted 中的reactor.connectTCP之后关闭连接

Question

我想问一个关于如何关闭twisted RPC中的连接的问题。
我知道有人问过类似的问题，但它似乎没有回答我的问题。
我正在做一些基本的连接，如下所示：

cfactory = pb.PBClientFactory()
reactor.connectTCP(<host>, <port>, cfactory)
dfr.addCallbacks(<callback>, <errfun>, ...)
...
(in the <callback> func)   remote.callRemote('myfunc', ...)

它一切正常并且可以完成我需要的工作。
但问题是，如果我检查它，我会看到连接仍然处于活动状态（“已建立”） netstat -a。
由于我在无限期运行的客户端和服务器之间执行此操作，因此我不能继续累积活动连接。
出于同样的原因我也无法停止反应堆。
那么，有没有一种方法可以关闭连接，而不需要创建自己的协议？
我想首先检查一下，因为除了这个事实之外，一切都处于工作状态 - 如果可能的话，我将只添加一个需要的东西，而不是从协议设置和所有开始。
感谢您的关注，如有任何一般性建议，我们将不胜感激。
托尼

Answer 1

remote 是一个RemoteReference。它有一个 Broker 属性，该属性是创建它的twisted.spread.pb.Broker 协议实例。与几乎所有协议一样，Broker 实例具有一个 transport 属性，该属性引用表示协议正在运行的连接的对象。

因此，remote.broker.transport.loseConnection() 应该执行您想要的操作。

还有其他选择。您可以在工厂捕获 Broker 实例：

class MyPBFactory(pb.PBClientFactory):
    def buildProtocol(self, addr):
        proto = pb.PBClientFactory.buildProtocol(self, addr)
        self.proto = proto
        return proto

现在您在工厂上有一个 proto 属性（但只有在实际建立连接之后，并且没有任何东西可以清理它，所以连接丢失后它仍然存在 - 但你可以处理这个）。