11

我有一个线程 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()

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

4

2 回答 2

2

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

在 python 中有几个库可以很好地使用它：

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

于 2012-11-22T00:02:55.047 回答
0

因此，您应该socket.settimeout(float)与clientsocket建议的评论之一一起使用。

您看不到任何差异的原因是，当您调用socket.recv(bufsize[, flags])并且超时用完时，socket.timeout会引发异常并且您捕获该异常并退出。

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

应该是这样的：

try:
      data = clientsocket.recv(1)
except timeout:
      #timeout occurred
      #handle it
      clientsocket.close()
      sys.exit()
于 2012-10-17T13:07:40.837 回答