python - 检查连接是否已使用 Twisted 关闭

Question

我正在使用 Twisted 编写代理服务器，但在检查与服务器的连接是否已关闭时遇到问题。

现在，我已经

客户端<->代理<->服务器

使用telnet进行测试，代理成功地将消息从客户端传递到服务器，并将服务器响应传递回客户端。但是，我的问题是，如果客户端发出命令关闭代理和服务器之间的连接，客户端和代理之间的连接仍然保留。

这是我的一些代码

    client_factory = protocol.ClientFactory()
    client_factory.protocol = ClientTelnetProtocol
    client_factory.proxy = self

    try: 
        clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
        clientsocket.connect(('localhost', 1234))
        clientsocket.close()
        reactor.connectTCP('localhost', 1234, client_factory)
    except Exception as err:
        print(err)
        self.transport.loseConnection()

在行

reactor.connectTCP('localhost', 1234, client_factory) 

我希望能够监视连接的状态并查看服务器是否关闭它，可能在 dataReceived() 上，或者如果可能的话，在服务器关闭与代理的连接时设置一个中断，并让proxy立即关闭与客户端的连接。

Answer 1

ITransport 将通过在 IProtocol 上调用 connectionLost 来通知其 IProtocol 连接丢失事件提供者。因此，如果您想对该事件使用react，您应该在您的协议(protocol)上实现 connectionLost (在本例中出现 ClientTelnetProtocol？)并将您的应用程序逻辑放入该方法中。一旦 ITransport 实现知道连接已丢失，就会调用此方法，因此它应该满足您的需求(请注意，它不是一个中断，因为 Twisted 是一个(很大程度上) )单线程协作多任务系统；因此，如果您有阻塞的应用程序代码(例如 clientsocket.connect)，Twisted 不会调用任何回调，直到完成后， react 堆重新获得控制权。但是，一旦有机会，它就会将事件(例如连接丢失)分派(dispatch)给处理程序(例如 connectionLost)。

我不明白为什么您的示例代码直接使用socket模块来创建然后丢弃到目标地址的连接。我的猜测是您正在尝试确定服务器是否正在接受连接。在这种情况下，您可能需要使用 the ClientFactory method clientConnectionFailed检测reactor.connectTCP尝试的连接是否失败，而不是使用socket模块并检查异常。您还可以使用Twisted's endpoint abstraction以Deferred 回调的形式获取此通知。

您可能还对 Tubes 感兴趣它提供了对数据流的更高级别的抽象。