先运行服务器再启动多个客户端，客户端通过多线程实现收发消息互不阻塞，服务器广播消息给所有客户端并管理连接列表，使用utf-8编码确保中文正常传输。
做一个简易的控制台多线程聊天程序，核心是让发送和接收消息互不阻塞。可以用 Python 的 socket 模块实现通信，用 threading 模块实现多线程。下面是一个简单的客户端-服务器模型示例，适合学习和理解基本原理。
1. 服务器端：同时处理多个客户端
服务器监听端口，为每个连接的客户端创建一个新线程来接收消息，同时能广播消息给所有客户端。
import socket import threadingclients = [] clients_lock = threading.Lock()
def broadcast(message, sender_conn): with clients_lock: for client in clients: if client != sender_conn: try: client.send(message) except: client.close() clients.remove(client)
def handle_client(conn, addr): print(f"[新连接] {addr} 已连接") with clients_lock: clients.append(conn)
while True: try: msg = conn.recv(1024) if msg: print(f"[来自 {addr}] {msg.decode('utf-8')}") broadcast(msg, conn) else: break except: break with clients_lock: if conn in clients: clients.remove(conn) conn.close() print(f"[断开] {addr} 已离开")def start_server(): server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server.bind(('127.0.0.1', 5000)) server.listen(5) print("服务器启动，等待连接...")
while True: conn, addr = server.accept() thread = threading.Thread(target=handle_client, args=(conn, addr)) thread.start()if name == "main": start_server()
2. 客户端：同时收发消息
客户端连接服务器后，开启两个线程：一个负责接收消息，一个负责发送输入内容。
import socket import threadingdef receive_messages(sock): while True: try: msg = sock.recv(1024).decode('utf-8') if msg: print(f"\n[收到] {msg}") print(">", end="", flush=True) # 重新打印输入提示 else: break except: print("\n连接已断开") break
def send_messages(sock): while True: msg = input("> ") if msg.lower() in ['exit', 'quit']: sock.close() break sock.send(msg.encode('utf-8'))
def start_client(): client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) client.connect(('127.0.0.1', 5000)) print("已连接到服务器")
# 启动接收线程 thread_recv = threading.Thread(target=receive_messages, args=(client,)) thread_recv.daemon = True thread_recv.start() # 主线程负责发送 send_messages(client)if name == "main": start_client()
3. 使用说明
- 先运行服务器代码（server.py）
- 再运行多个客户端代码（client.py），每个客户端在独立的控制台窗口中运行
- 在客户端输入消息，按回车发送，所有其他客户端都能看到
- 输入 exit 或 quit 可退出客户端
4. 关键点说明
- 多线程：客户端用一个线程收消息，主线程发消息，避免 input() 阻塞接收
- 广播机制：服务器收到消息后转发给其他客户端
- 连接管理：用列表保存客户端连接，异常时自动清理
- 编码：统一使用 utf-8 编码处理中文
基本上就这些。不复杂但容易忽略细节，比如输入提示被覆盖、连接未正确关闭等。可以在此基础上加用户名、私聊、颜色显示等功能。
