客户端连接不稳定的python套接字服务器/客户端协议(protocol)

Question

我有一个线程化的 python 套接字服务器，它为每个连接打开一个新线程。

线程是一种非常简单的基于问答的交流。 基本上客户端发送初始数据传输，服务器让它运行一个外部应用程序，该应用程序对传输进行处理并返回服务器将发回的回复，循环将再次开始，直到客户端断开连接。

现在，因为客户端将在手机上，因此连接不稳定，我得到打开的线程不再连接，并且因为循环以 recv 开始，所以很难以这种方式中断连接丢失。

我正在考虑在 recv 之前添加一个发送以测试连接是否仍然存在，但如果客户端在我的故障安全发送后断开连接，这可能根本无济于事，因为客户端仅每 5 秒发送一次数据流。

我注意到 recv 有时会中断，但并非总是如此，在那些情况下，我会留下使用资源的僵尸线程。

这也可能是我的系统被 DOSed 的一个可靠漏洞。 从星期四开始，我已经查看了 python 手册并进行了谷歌搜索，试图为此找到一些东西，但我发现的大多数东西都与客户端和非阻塞模式有关。

谁能指出我正确的方向，找到解决此问题的好方法？

代码示例:

听众:

serversocket = socket(AF_INET, SOCK_STREAM)
serversocket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
serversocket.bind(addr)
serversocket.listen(2)
logg("Binded to port: " + str(port))

# Listening Loop
while 1:
  clientsocket, clientaddr = serversocket.accept()
  threading.Thread(target=handler, args=(clientsocket, clientaddr,port,)).start()

# This is useless as it will never get here
serversocket.close()

处理程序:

  # Socket connection handler (Threaded)
  def handler(clientsocket, clientaddr, port):
    clientsocket.settimeout(15)

    # Loop till client closes connection or connection drops
    while 1:
      stream = ''
      while 1:
        ending = stream[-6:] # get stream ending
        if ending == '.$$$$.':
          break

        try:
          data = clientsocket.recv(1)
        except:
          sys.exit()

        if not data:
          sys.exit()
          # this is the usual point where thread is closed when a client closes connection normally

        stream += data

      # Clear the line ending
      stream = base64.b64encode(stream[:-6])

      # Send data to be processed
      re = getreply(stream)

      # Send response to client
      try:
        clientsocket.send(re + str('.$$$$.'))
      except:
        sys.exit()

如您所见，如果连接失败，至少有一个应该触发退出的三种情况，但有时它们不会。

Answer 1

抱歉，但我认为在这种情况下threaded 的想法并不好。因为你不需要在这些线程( worker ？)中处理/做很多事情，而且大多数时候这些线程都在等待套接字(是阻塞操作，不是吗？)我建议阅读 event-driven programming .根据套接字，这种模式非常有用，因为您可以在一个线程中完成所有工作。您一次与一个套接字通信，但其余连接只是在等待数据，因此几乎没有丢失。当您发送几个字节时，您只需检查是否有另一个连接需要携带。你可以阅读 select 和 epoll 。

在 python 中有几个库可以很好地处理这个问题:

• libev(c 库包装器)- pyev
• tornado
• twisted

我在一些项目中使用了 tornado，它很好地完成了这项任务。 Libev 也不错，但它是一个 c 包装器，所以它有点低级(但对于某些任务来说非常好)。