python 聊天室，双方可以不断给对方发送消息并且print出来，且不需要等待其中一方回复

<think>我们正在设计一个支持双方实时发送和接收消息的Python聊天室程序。要求使用多线程实现消息的收发，使得发送和接收操作互不阻塞。 根据提供的引用内容，我们可以参考一些基本的socket和多线程编程方法。 基本思路： 1. 使用socket进行网络通信（TCP协议）。 2. 客户端需要两个线程：一个用于持续接收消息（recv），另一个用于持续发送消息（input）。 3. 接收线程需要一直运行，当收到特定消息（如"exit"）时，关闭连接并退出程序。 4. 发送线程同样需要一直运行，直到用户输入退出命令（如"exit"），然后关闭连接并退出程序。 注意：由于有两个线程，我们需要确保在退出时能够正确关闭资源并终止线程。 根据引用[1]和引用[2]的示例代码，我们可以整合出一个改进的版本，满足实时收发且不阻塞等待。 改进点： - 使用多线程分离发送和接收功能。 - 设置一个全局标志（如`running`）来控制线程的退出。 - 在退出时关闭socket连接，并确保线程能够正常结束。 下面我们编写代码：</think>### Python 实时聊天室实现（多线程非阻塞） 要实现支持双方实时收发消息的聊天室程序，核心是使用**多线程分离消息发送和接收功能**，避免阻塞等待。以下是完整实现方案： ```python import socket import threading import sys def receive_messages(client_socket, running): """持续接收消息的线程函数""" while running[0]: try: # 非阻塞接收消息 data = client_socket.recv(1024).decode('utf-8') if not data: print("\n[系统] 连接已断开") break print(f"\n[对方] {data}") sys.stdout.flush() except ConnectionResetError: print("\n[系统] 连接被对方关闭") running[0] = False break def main(): # 创建TCP socket client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 连接配置 server_ip = input("输入服务器IP: ") server_port = int(input("输入服务器端口: ")) try: client_socket.connect((server_ip, server_port)) print(f"[系统] 已连接到 {server_ip}:{server_port}") except ConnectionRefusedError: print("[错误] 连接被拒绝，请检查服务器状态") return except Exception as e: print(f"[错误] 连接失败: {str(e)}") return # 共享运行状态标志 running = [True] # 启动接收消息线程 recv_thread = threading.Thread( target=receive_messages, args=(client_socket, running), daemon=True ) recv_thread.start() print("\n[提示] 输入消息后按回车发送，输入'exit'退出\n") # 主线程处理消息发送 try: while running[0]: msg = input("[我] ") if msg.lower() == 'exit': running[0] = False break client_socket.sendall(msg.encode('utf-8')) except KeyboardInterrupt: print("\n[系统] 用户中断程序") finally: # 清理资源 client_socket.sendall("exit".encode('utf-8')) client_socket.close() print("[系统] 连接已关闭") if __name__ == "__main__": main() ``` ### 关键技术点解析 1. **双线程架构** - 主线程：处理用户输入和消息发送 - 接收线程：持续监听服务器消息 - 通过`daemon=True`确保程序退出时线程自动终止 2. **非阻塞通信** - 接收线程独立运行，不会阻塞发送操作 - 发送操作即时执行，无需等待接收响应 - 使用`sys.stdout.flush()`确保实时显示接收消息 3. **连接管理** - 共享状态变量`running`控制线程退出 - 异常处理网络中断（`ConnectionResetError`） - `finally`块保证资源释放 4. **编码规范** - 统一使用UTF-8编码避免乱码 - 明确的系统提示信息 - 支持优雅退出（输入`exit`或`Ctrl+C`） ### 使用说明 1. 双方均运行此程序 2. 一方作为服务器时需开启端口监听（可用`nc -l <端口号>`测试） 3. 输入对方IP和端口建立连接 4. 实时收发消息，界面显示效果： ``` [我] 你好！ [对方] 收到，你在哪里？ [我] exit [系统] 连接已关闭 ``` ### 性能优化建议 - 增加心跳机制检测连接状态 - 使用消息队列处理高并发场景 - 添加消息加密（如TLS） - 实现消息历史记录功能