python - 向所有客户端发送消息

Question

这可能是非常简单的套接字消息交换编程，但由于我对套接字的想法很脆弱，我无法真正让它正常工作，所以我寻求帮助。

场景:两个客户端发送消息。第一个发送 Halo 和 Seeya。 在第一个发送这些消息后，第二个发送Hello 和Bye(此客户端将只休眠 6 秒以保持此顺序)。对于所有消息，服务器回复(原始消息)，客户端(号码)!并将回复消息广播到两个客户端。

理想情况下，两个客户端的结果如下所示:

    Halo, client 1!
    Seeya, client 1!

    Hello, client 2!
    Bye, client 2 !

我无法为每个客户编号，但我的代码运行起来很奇怪。

服务器

    import socket             

    clients = []

    # send msgs to every client
    def broadcast(message):          
        for client in clients : 
            client.send(message)

    # connection part
    s = socket.socket()         
    s.bind(('127.0.0.1', 7070)) 
    s.listen(2)    

    while True:
        c, addr = s.accept()
        if c:
            clients.append(c)
        msg = c.recv(1024).decode()
        msg += ', client!'
        broadcast(msg.encode())

客户1

    ### here goes connection part ###

    s.send(("Halo").encode())
    print(f"server = {(s.recv(1024)).decode()}")

    # I've tried adding socket closing/connection part here

    s.send(("Seeya").encode())
    print((s.recv(1024)).decode())

    time.sleep(3)
    s.close()

client2 - 首先连接，但等待 6 秒消息顺序

    ### here goes connection part ###

    time.sleep(6)               # waits for message order
    s.send(("Hello").encode())
    print(f"server = {(s.recv(1024)).decode()}")

    # I've tried adding socket closing/connection part here

    s.send(("Bye").encode())
    print((s.recv(1024)).decode())
    time.sleep(3)
    s.close()

我得到的结果是...

    # On client 1 side 
    Halo, client!                  # no Seeya, Hello, Bye
                                   # connection isn't closed

    # On client 2 side
    Hello, client!                 # no Seeya, Bye
    Halo, client!                  # connection is closed

Answer 1

这里有几个问题。第一个也是主要的一个是你的服务器的主循环被搞砸了。每次通过循环，您的服务器都希望接受 连接。因此，第一个连接的客户端被接受并立即收到它的第一条消息。但是另一个客户端尚未被接受，因此不会收到第一条消息。然后第二个客户端连接被接受，它的第一条消息然后被发送到两个客户端，但随后循环再次迭代并且不再从服务器发送消息直到第三个​​客户端 连接。等等

所以需要把接受连接和接收消息分开。这可以通过多种方式完成。最直接的方法是使用 select 函数同时等待多个套接字。也就是说，如果您有一个套接字列表，包括监听套接字和以前接受的套接字，您将执行如下操作:

# List starts with only listening socket
list_of_sockets = [lsock]
...
while True:
    # Wait until some socket becomes "readable"
    rfds, _wfds, _xfds = select.select(list_of_socks, [], [])
    for sock in rfds:
        if sock is lsock:
            # Listening socket ready. Accept new connection
            c, addr = lsock.accept()
            print(f"Accepted {c}")
            list_of_socks.append(c)
        else:
            msg = sock.recv(1024)
            if msg:
                # Received data from connected socket. Send to all
                print(f"Got {msg.decode()} from {sock}")
                broadcast(msg)
            else:
                # Got end of file (this client closed). Remove client from list
                print(f"Closed {sock}")
                list_of_socks.remove(sock)

上面的服务器代码不会解决您的代码的另一个问题:您不能假设您发送的每条消息都将作为一个不同的单元接收。也就是说，如果服务器在您(客户端)完成 recv 之前发送“Halo”然后发送“Hello”，那么很可能所有数据一举退还；那就是“HaloHello”。

因此，通常您会希望在数据中放置某种分隔符(如换行符 [\n] -- 但随后您需要解析接收到的数据)或者，更好的是，在每条消息前放置一个定长字段，给出后续变长部分的长度，这样就可以一次只接收和处理一条消息。 (在 python 中，这通常涉及使用 struct 模块的 pack 和 unpack 函数。)因此，您当前的客户端代码可能无法正常工作根据需要对消息进行排序。

另外——尽管不太可能导致问题——send 也是如此:你不应该假设 send(N) 发送的正是 N 字节。它可能会发送 1、2、3 或 N-1 字节。您可以使用 sendall 来确保发送所有字节。