### 基于Python Socket实现聊天室的代码示例 以下是一个基于 Python 的简易聊天室实现代码示例，使用了 `socket` 模块和多线程技术来支持多人同时在线聊天[^1]。服务器端会接收所有客户端的消息，并将消息广播给所有连接的客户端。 #### 服务器端代码 ```python import socket import threading # 定义服务器地址和端口 HOST = '127.0.0.1' PORT = 12345 # 创建 socket 对象 server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server.bind((HOST, PORT)) server.listen() # 存储客户端连接和昵称 clients = [] nicknames = [] # 广播消息给所有客户端 def broadcast(message): for client in clients: client.send(message) # 处理客户端消息 def handle(client): while True: try: # 接收消息并广播 message = client.recv(1024) broadcast(message) except: # 如果发生异常（如客户端断开），移除客户端 index = clients.index(client) clients.remove(client) client.close() nickname = nicknames[index] nicknames.remove(nickname) broadcast(f'{nickname} 离开了聊天室！\n'.encode('utf-8')) break # 接受新连接 def receive(): while True: client, address = server.accept() print(f"与 {str(address)} 建立连接") # 请求并存储昵称 client.send('NICK'.encode('utf-8')) nickname = client.recv(1024).decode('utf-8') nicknames.append(nickname) clients.append(client) print(f'昵称为 {nickname} 的用户加入了聊天室') broadcast(f'{nickname} 加入了聊天室！\n'.encode('utf-8')) client.send('连接到服务器！\n'.encode('utf-8')) # 为每个客户端启动一个线程 thread = threading.Thread(target=handle, args=(client,)) thread.start() print("服务器已启动，等待连接...") receive() ``` #### 客户端代码 ```python import socket import threading # 定义服务器地址和端口 HOST = '127.0.0.1' PORT = 12345 # 创建 socket 对象 client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) client.connect((HOST, PORT)) # 获取昵称 nickname = input("请输入你的昵称: ") # 接收消息 def receive(): while True: try: message = client.recv(1024).decode('utf-8') if message == 'NICK': client.send(nickname.encode('utf-8')) else: print(message) except: print("出现错误，已断开连接") client.close() break # 发送消息 def write(): while True: message = f'{nickname}: {input("")}' client.send(message.encode('utf-8')) # 启动接收和发送线程 receive_thread = threading.Thread(target=receive) receive_thread.start() write_thread = threading.Thread(target=write) write_thread.start() ``` 上述代码实现了基本的聊天室功能，包括多客户端连接、消息广播以及异常处理[^4]。