如何在Python中实现简易的TCP聊天室服务端与客户端-Python教程-PHP中文网

直接用 socket 实现 TCP 聊天室可行但需自行处理连接管理、消息广播、粘包及异常断连；仅靠 socket.accept() + recv() 循环无法应对多客户端并发、网络闪断、空数据、快速重连等真实问题。

如何在python中实现简易的tcp聊天室服务端与客户端

直接用 socket 实现 TCP 聊天室是可行的，但必须自己处理连接管理、消息广播、粘包和客户端异常断开——不加心跳或超时机制，服务端很容易卡死或漏消息。

为什么不能只靠 `socket.accept()` + `recv()` 循环？

真实场景下，多个客户端同时发消息、中途断网、发送空数据、快速重连都会暴露基础 socket 的缺陷：

recv() 在无数据时默认阻塞，一个客户端卡住会拖慢整个 select() 或线程轮询
没有消息边界：客户端连续发 "hi" 和 "ok"，服务端可能一次 recv(1024) 收到 "hiok"
recv() 返回 0 才代表对端关闭，但网络闪断时可能长时间收不到任何数据，连接就“挂着”不释放

用 `select` 实现非阻塞多客户端管理（服务端核心）

不用 threading 或 asyncio 也能支撑 10+ 用户，关键是把所有 socket 设为非阻塞，并用 select.select() 统一监听可读/可写事件：

import socket, select
<p>server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(False)  # 必须设为非阻塞
server.bind(('0.0.0.0', 8888))
server.listen(5)</p><p>inputs = [server]
clients = {}  # {sock: addr}</p><p>while True:
readable, _, exceptional = select.select(inputs, [], inputs, 1.0)  # 1秒超时
for s in readable:
if s is server:
conn, addr = server.accept()
conn.setblocking(False)
inputs.append(conn)
clients[conn] = addr
print(f"New client: {addr}")
else:
try:
data = s.recv(1024)
if data:</p><h1>按 \n 拆分消息（简单粘包处理）</h1><pre class="brush:php;toolbar:false;">                lines = data.decode('utf-8').strip().split('\n')
                for line in lines:
                    if line:
                        broadcast(s, f"[{clients[s]}] {line}")
            else:
                raise ConnectionResetError
        except (ConnectionResetError, ConnectionAbortedError, OSError):
            inputs.remove(s)
            addr = clients.pop(s, None)
            print(f"Client {addr} disconnected")
            s.close()
for s in exceptional:
    inputs.remove(s)
    clients.pop(s, None)
    s.close()

注意：select 在 Windows 和 Linux 均可用，但文件描述符数量有上限（通常 1024），别硬扛几百人。

客户端如何避免 `send()` 阻塞和消息丢失？

用户敲回车就发，但 send() 可能只发出部分字节，尤其在网络拥塞时。必须检查返回值并缓存未发完的数据：

macOS UI 自动化技能包 —— 用 Python 控制你的 Mac

让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac，无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启：辅助功能 + 屏幕录制权限

下载

永远用 sendall() 替代 send() —— 它内部会循环调用 send() 直到全部发出或出错
输入带换行符（\n），服务端才好按行解析；否则得自己实现长度头或分隔符协议
不要在主线程里做阻塞 recv()，否则收消息时无法输入。用 select 或起一个接收线程

简易客户端接收逻辑示例：

import socket, select, sys
<p>client = socket.socket()
client.connect(('127.0.0.1', 8888))</p><p>while True:
readable, <em>, </em> = select.select([client, sys.stdin], [], [], 0.1)
for r in readable:
if r is client:
try:
data = client.recv(1024)
if not data:
print("\nServer closed")
exit()
print(f"\r{data.decode('utf-8')}\n> ", end='')
sys.stdout.flush()
except OSError:
print("\nDisconnected")
exit()
elif r is sys.stdin:
msg = sys.stdin.readline().strip()
if msg:
client.sendall((msg + '\n').encode('utf-8'))
</p>