发送/接收 Python 聊天室不工作（更新）

Question

我问了一个关于我的服务器到客户端代码的问题，因为我遇到了很多问题，有人告诉我解决问题的方法是进行点对点聊天，我现在已经这样做了。

服务器.py

import socket, threading

host = "127.0.0.1"
port = 4000
s = socket.socket()
s.bind((host,port))
s.listen(5)
client_sockets = []
users = []
print("Listening")

def handle_client(conn):
    while True:
        try:
            data = conn.recv(512)
            for x in client_sockets:
                try:
                    x.send(data)
                except Exception as e:
                    print(e)
        except:
            pass

while True:
    conn,addr = s.accept()
    client_sockets.append(conn)
    print("Connections from", addr[0], "on port",addr[1])
    threading.Thread(target = handle_client,args = (conn,)).start()

客户端.py

import socket,threading

host = "127.0.0.1"
port = 4000
s = socket.socket()
s.connect((host,port))

def echo_data(sock):
   while True:
      try:
         data = sock.recv(512)
         print(data)
      except:
         pass

while True:
   threading.Thread(target=echo_data,args=(s,)).start()
   msg = input("Enter your message : ")
   s.send(msg.encode())

问题是，当我运行客户端并尝试与另一个客户端交谈时，除非另一个客户端按 Enter，否则不会发送消息，这也让我遇到了第二个问题，当客户端相互发送消息时，他们以这种格式收到：

b'hi'Enter your message :

This is the link to my previous question

Answer 1

我将从与问题不直接相关的一般问题开始：

• except: pass 通常是个坏主意，特别是当出现问题时，因为它会隐藏潜在有用的消息。它是语言允许的，但不应存在于实际代码中

• 在 client.py 中，您为每条消息启动一个接收线程，而整个客户端只需要一个接收线程。您应该在循环外启动线程：

  threading.Thread(target=echo_data,args=(s,)).start()
  while True:
     msg = input("Enter your message : ")
     s.send(msg.encode())
  

现在回答问题：

• 除非其他客户端点击回车，否则消息不会被发送

  这可能是由 IDE 引起的。具体来说，众所周知，IDLE 在多线程脚本中表现不佳。如果您正确使用一个接收线程并从命令行 (python client.py) 启动脚本，它应该可以正常工作

• 消息以这种格式接收：b'hi'Enter your message

  sock.recv(sz) 返回一个字节串。您需要对其进行解码以将其转换为 Python 3 unicode 字符串：

   data = sock.recv(512)
   print(data.decode())
  

但这还不是全部。这对测试来说很好，但您至少应该允许客户端与服务器断开连接，并且当它们断开连接时，将它们从client_sockets 中删除。而且通常不向发件人发回消息。所以你可以改进 server.py 循环：

while True:
    try:
        data = conn.recv(512)
        for x in client_sockets:
            if x != conn:         # do not echo to sender
                x.send(data)
    except Exception as e:        # problem in connection: exit the loop
        print(e)
        break
# clear the connection
conn.close()
client_sockets.remove(conn)