先运行服务器再启动多个客户端，客户端通过多线程实现收发消息互不阻塞，服务器广播消息给所有客户端并管理连接列表，使用utf-8编码确保中文正常传输。
做一个简易的控制台多线程聊天程序，核心是让发送和接收消息互不阻塞。可以用 Python 的 socket 模块实现通信，用 threading 模块实现多线程。下面是一个简单的客户端-服务器模型示例，适合学习和理解基本原理。
1. 服务器端：同时处理多个客户端
服务器监听端口，为每个连接的客户端创建一个新线程来接收消息，同时能广播消息给所有客户端。
import socket
import threading
<p>clients = []
clients_lock = threading.Lock()</p><p>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)</p><p>def handle_client(conn, addr):
print(f"[新连接] {addr} 已连接")
with clients_lock:
clients.append(conn)</p><pre class='brush:php;toolbar:false;'>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 threading
<p>def 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</p><p>def send_messages(sock):
while True:
msg = input("> ")
if msg.lower() in ['exit', 'quit']:
sock.close()
break
sock.send(msg.encode('utf-8'))</p><p>def start_client():
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(('127.0.0.1', 5000))
print("已连接到服务器")</p><pre class='brush:php;toolbar:false;'># 启动接收线程
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 编码处理中文
基本上就这些。不复杂但容易忽略细节，比如输入提示被覆盖、连接未正确关闭等。可以在此基础上加用户名、私聊、颜色显示等功能。
