扭曲的视角经纪人服务器端延迟

Question

我正在使用twisted 的Perspective Broker 在客户端和服务器之间进行通信。客户端向服务器请求远程方法“remote_ssh”。这会导致 PB 服务器使用 Paramiko 的 SSH 库启动 SSH 连接并从远程设备检索配置。

这一切都工作正常，但是当我对多个远程设备执行此操作时，我看到以下行为 - Perspective Broker 客户端将所有请求发送到 PB 服务器。然后，PB 服务器将一一执行这些请求（这很好），但在它们全部完成之前它不会返回任何结果。

这是相关的 PB 服务器端代码：

class RMethods(pb.Root):

    def remote_ssh(self, aDict):

        self.login('SSH', aDict)        # Login to remote device
        response = self.aSSH.retrieve() # Retrieve the config
        self.aSSH.close()

        return response


if __name__ == "__main__":
    reactor.listenTCP(1885, pb.PBServerFactory(RMethods()))
    reactor.run()

通过查看各种系统级信息（TCPDump 和 netstat），我看到以下内容（假设远程方法的 5 次调用）：

发生从 PB 客户端到 PB 服务器的五个远程设备的调用 remote_ssh大约在同一时间，

   self.login device 1
   self.aSSH.retrieve() device 1
   self.aSSH.close() device 1

   self.login device 2
   self.aSSH.retrieve() device 2
   self.aSSH.close() device 2

   ...

   self.login device 5
   self.aSSH.retrieve() device 5
   self.aSSH.close() device 5

   return results for all 5 devices  

我不明白为什么它要等待返回结果（即为什么它要等到 device5 完成后再返回 device1 的结果）。

Answer 1

发生这种情况是因为反应器有机会运行之前无法发送响应。如果所有五个请求几乎同时到达，则反应堆可能会唤醒一次并同时注意到所有五个请求。它将把所有五个都分派到 PB 服务器。 remote_ssh 方法将为其中之一提供服务，并始终阻塞。完成后，响应将（几乎肯定）被排队。然后，remote_ssh 方法将为下一个方法提供服务，并且该响应将排队。依此类推，直到所有请求都得到处理。然后反应堆将完成最初的 5 个事件组的调度，并继续进行下一件事。当它继续前进时，它会发现数据准备好发送并开始发送。

换句话说，阻塞会阻止反应器运行，包括阻止其发送准备发送的输出。

您可以尝试使用 Twisted Conch 作为 SSH 客户端，这可以让您在不阻塞的情况下完成 SSH 工作，或者您可以尝试使用现有的带有线程（假设可以使其成为线程安全）或多进程的 SSH 代码。