1

我有一些测试客户端每次都遇到相同的问题。客户端可以连接，并且可以发送第一条消息，但之后服务器停止响应该客户端。我怀疑这个问题与 s.accept() 有关，但我不确定到底出了什么问题或如何解决它。

def startServer():
    host = ''
    port = 13572
    backlog = 5
    size = 1024

    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((host,port))
    s.listen(backlog)

    print "Close the command prompt to stop Gamelink"

    while 1:
        try:
            client, address = s.accept()
            data = client.recv(size)
            if data:
                processData(data)
                client.send("OK")
            else:
                print "Disconnecting from client at client's request"
                client.close()
        except socket.error, (value, message):
            if s:
                print "Disconnecting from client, socket issue"
                s.close()
            print "Error opening socket: " + message
            break
        except:
            print "Gamelink encountered a problem"
            break
        print "End of loop"
    client.close()
    s.close()

该服务器旨在通过本地网络访问，并且它需要重量轻且响应速度非常快，因此如果其他实现（例如基于线程）会更好地满足这些要求，请告诉我。预期的应用程序将用作远程游戏键盘，因此需要低资源使用和高速。

4

1 回答 1

0

直接使用编写服务器socket会很困难。正如基思所说，您需要以某种方式多路复用连接，例如使用select或poll或线程或fork。您可能认为您只需要一个连接，但是当出现问题并且连接丢失时您会怎么做？如果您的服务器尚未意识到连接丢失，它是否能够响应来自客户端的重新连接尝试？

如果你的网络需求是基本的，你也许可以让其他东西为你处理所有的倾听、接受和分叉的东西。您没有指定平台，但此类程序的示例在Mac OS上启动，在 Linux 上启动xinetd 。这些工具的细节有所不同，但基本上你可以在一些配置文件中配置它们，以侦听某个端口上的连接。当他们得到它时，他们会负责建立连接，然后他们会exec()使用您的程序stdin并stdout针对套接字，因此您可以简单地使用您可能已经知道的所有基本 IO，例如print和sys.stdin.read()。

像 xinitd 和 launchd 这样的解决方案的问题在于，对于每个新连接，它们必须fork()和exec()程序的新实例。这些是相对繁重的操作，因此大量连接或高新连接率可能会达到服务器的限制。但更糟糕的是，由于每个连接都在一个单独的进程中，因此很难在它们之间共享数据。此外，您可能会发现在进程之间进行通信的大多数解决方案都涉及阻塞 API，现在您又回到了与select线程或类似线程进行多路复用的问题。

如果这不能满足您的需求，我认为您最好学习使用更高级别的网络框架，该框架将处理您走上socket. 我建议的一个这样的框架是Twisted。除了处理连接处理的普通细节以及在它们之间多路复用 IO 的更复杂的任务之外，您还将拥有一个庞大的工具库，这将使您的协议的实现更加容易。

于 2012-12-31T04:21:30.533 回答