0

我已经挖掘了一段时间，我已经有了很好的理解，没有什么能完全达到我想要做的事情：

我需要一个可以连接多个客户端的服务器。每隔一段时间，客户端就会向服务器查询一组要处理的新数字（本质上是分布式计算），然后服务器将其发送回查询的客户端。

我如何知道哪个客户端查询了服务器，以便我可以回复它？

我对 Python 还很陌生，select() 函数本身有点令人困惑。我能够接受新连接并获得输入，但服务器似乎不知道哪个客户端正在与它交谈（或者我的调试文本可能不正确，它确实知道？？）。

无论如何，这是服务器的代码：

while running:
    #select returns 3 subsets of the input containing sockets that have stuff to be read, empty buffer for writing, or an error
    readers, writers, error = select.select(input, output, errors)
    for s in readers:
        if s == serversocket:
            #readable server socket is ready for connection
            connection, client_addr = s.accept()
            print >> sys.stderr, 'new connection from', client_addr
            connection.setblocking(0)
            #clients.append([client_addr, performance])
            input.append(connection)
            output.append(connection)
        else:
            #readable socket, not ready for new connection
            data = s.recv(1024)
            print >> sys.stderr, "readable socket, not ready for new connection"
            if data:
                #the socket actually has data (put Compute process data into list)
                print >> sys.stderr, "Data received"
                substring = data[0:data.find("sss")];
                print >> sys.stderr, 'received %s from %s' % (substring, client_addr)
                if substring == "-get":
                    print >> sys.stderr, 'received -get command'
                    determinerange()
                    print >> sys.stderr, 'sending range of %d to %d', currentlow, currenthigh
                    temp = currentlow+"\0"
                    connection.send(currentlow)
                    temp = currenthigh+"\0"
                    connection.send(currenthigh)
                elif substring == "-k":
                    print >> sys.stderr, 'received -k, stopping'

本质上，它接收某种命令，然后转身发送它需要的数据。如果您想知道，该服务器必须与我也在编写的 C 程序通信，该程序实际上进行计算。这就是为什么我要附加换行符“\0”字符。如果它从任何客户端接收到 -k，它需要停止每个客户端并退出。

注意：我只能使用标准的 python 库。我无法得到任何能让事情变得更容易的额外东西:)

提前感谢大家的帮助！

4

2 回答 2

1

您不需要知道哪个客户。套接字是所有意图和目的的客户端。只需通过您收到请求的同一个套接字发送响应。

于 2013-03-17T00:07:02.660 回答
1

尝试替换行：

                connection.send(currentlow)
                ...
                connection.send(currenthigh)

经过：

                s.send(currentlow)
                ...
                s.send(currenthigh)

这会将消息发送到您从中收到一些数据的当前客户端，而不是存储在变量连接中的客户端。

于 2013-03-17T00:37:06.367 回答