1

我一直在尝试制作一个多客户端服务器,我终于拥有并且它运行良好,但我现在想做的是让客户端输入他们的名字,而不是获取客户端地址,然后程序会说“鲍勃:大家好”而不是“127.0.0.1:大家好”。

我使用了 python 文档中的预制服务器和客户端。这是服务器:

import socketserver

class MyUDPHandler(socketserver.BaseRequestHandler):


    def handle(self):
        data = self.request[0].strip()
        name = self.request[0].strip()
        socket = self.request[1]
        print(name,"wrote:".format(self.client_address[0]))
        print(data)
        socket.sendto(data.upper(), self.client_address)

if __name__ == "__main__":
    HOST, PORT = "localhost", 9999
    server = socketserver.UDPServer((HOST, PORT), MyUDPHandler)
    server.serve_forever()

这是客户:

import socket
import sys

HOST, PORT = "localhost", 9999
data = "".join(sys.argv[1:])
name = "".join(sys.argv[1:])


sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

sock.sendto(bytes(name + "Bob", 'utf-8'), (HOST, PORT))
sock.sendto(bytes(data + "hello my name is Bob", "utf-8"), (HOST, PORT))
received = str(sock.recv(1024), "utf-8")

print("Sent:     {}".format(data))
print("Received: {}".format(received))

一切正常,但由于某种原因,一旦客户端连接,我就会在服务器中得到它。

b'Bob'  wrote:
b'Bob'
b'hello my name is bob'  wrote:
b'hello my name is bob'

我希望它像:

Bob wrote:
b'Hello my name is bob'

我希望有人可以帮助我,谢谢。

4

1 回答 1

5

您在这里遇到了多个问题。


首先是您bytes直接打印对象:

print(name,"wrote:".format(self.client_address[0]))

这就是为什么你得到b'Bob' wrote:而不是Bob wrote:. 当您bytes在 Python 3 中打印对象时,会发生这种情况。如果要将其解码为字符串,则必须明确执行此操作。

您的代码可以在所有地方执行此操作。decode使用andencode方法通常比使用strandbytes构造函数更干净,如果你已经在使用format,还有更好的方法来处理这个问题,但要坚持你现有的风格:

print(str(name, "utf-8"), "wrote:".format(self.client_address[0]))

接下来,我不确定您为什么要调用format没有格式参数的字符串,或者为什么要将多参数print函数和format调用混合在一起。看起来您正在尝试获取self.client_address[0],但您没有这样做。再说一次,您想要的输出没有显示它,所以……format如果您不想要它,只需删除该调用,如果您愿意,请{}在格式字符串的某处添加。(你也可能想要解码client_address[0]。)


接下来,将相同的值存储在nameand中data

data = self.request[0].strip()
name = self.request[0].strip()

因此,当您稍后执行此操作时:

print(data)

......这只是name再次打印 - 而且,再次,没有解码它。所以,即使你修复了解码问题,你仍然会得到这个:

Bob wrote:
Bob

… 而不仅仅是:

Bob wrote:

要解决这个问题,只需摆脱data变量和print(data)调用。


接下来,您将发送两个单独的数据包,一个带有 ,name另一个带有data,但尝试从每个数据包中恢复这两个数据包。因此,即使您解决了上述所有问题,您也会将Bob一个数据包作为名称,并hello my name is bob在下一个数据包中,导致:

Bob wrote:
hello my name is bob wrote:

如果您希望它是有状态的,则需要将状态实际存储在某处。在你的例子中,状态非常简单——只是一个标志,表明这是否是来自给定客户端的第一条消息——但它仍然必须去某个地方。一种解决方案是使用字典将新状态与每个地址相关联——尽管在这种情况下,由于状态要么“以前见过”,要么根本没有,我们可以只使用一个集合。

把它们放在一起:

class MyUDPHandler(socketserver.BaseRequestHandler):
    def __init__(self, *args, **kw):
        self.seen = set()
        super().__init__(*args, **kw)

    def handle(self):
        data = self.request[0].strip()
        addr = self.client_address[0]
        if not addr in self.seen:
            print(str(data, "utf-8"), "wrote:")
            self.seen.add(addr)
        else:
            print(str(data, "utf-8"))
        socket.sendto(data.upper(), self.client_address)

同时,您实际上想要的似乎是将第一个请求的名称存储为每个客户端的状态,以便您可以在以后的每个请求中重用它。这几乎一样容易。例如:

class MyUDPHandler(socketserver.BaseRequestHandler):
    def __init__(self, *args, **kw):
        self.clients = {}
        super().__init__(*args, **kw)

    def handle(self):
        data = str(self.request[0].strip(), 'utf-8')
        addr = self.client_address[0]
        if not addr in self.clients:                
            print(data, "joined!")
            self.clients[addr] = data
        else:
            print(self.clients[addr], 'wrote:', data)
        socket.sendto(data.upper(), self.client_address)
于 2013-06-03T20:13:09.127 回答