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

Question

我有一个线程python套接字服务器,为每个连接打开一个新线程.

线程是基于问答的非常简单的通信.基本上客户端发送初始数据传输,服务器将其运行一个外部应用程序,对传输执行操作并返回服务器将发回的回复,并且循环将再次开始直到客户端断开连接.

现在因为客户端将在移动电话上,因此连接不稳定,我不再连接开放线程,并且因为循环以recv开始,所以很难以这种方式打破丢失的连接.

我正在考虑在recv之前添加一个send来测试连接是否仍然存在但是如果客户端在我的故障安全发送后断开连接,这可能根本不起作用,因为客户端仅每5秒发送一次数据流.

我注意到recv有时会破坏但并非总是如此,在这种情况下,我会使用资源留给僵尸线程.

这也可能是我的系统被DOS操作的一个可靠漏洞.我已经浏览了python手册和Google搜索,因为我周四试图找到一些东西,但我找到的大多数东西都与客户端和非阻塞模式有关.

任何人都可以指出我正确的方向,以解决这个问题吗？

代码示例:

监听器:

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在这种情况下这个想法不好。由于您不需要在这些线程（工作线程？）中处理/做很多事情，并且大多数时候这些线程都在等待套接字（是阻塞操作，不是吗？）我建议阅读有关事件的信息驱动编程。根据套接字，这种模式非常有用，因为您可以在一个线程中完成所有操作。您一次与一个套接字通信，但其余连接只是等待数据，因此几乎没有丢失。当您发送几个字节时，您只需检查是否另一个连接需要携带。您可以阅读有关select 和epoll 的内容。

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

• libev（c 库包装器）- pyev
• 龙卷风
• 扭曲的

我在一些项目中使用了tornado，并且它很好地完成了这项任务。Libev 也很好，但它是一个 c 包装器，所以它有点low-level（但对于某些任务来说非常好）。