### Python 实现监听客户端消息并确保本地输出不受影响 为了实现在 Python 中监听客户端消息而不阻塞本地输出，可以采用 `select` 技术来管理多个套接字连接。这种方式能够有效避免因等待客户端消息而导致程序卡死或报错的情况。 以下是具体的实现方法： #### 使用 `select` 和 `socket` 的非阻塞模式 可以通过配置 `socket` 为非阻塞模式，并利用 `select.select()` 来检测是否有可读的数据流。如果没有数据，则继续执行其他逻辑[^1]。 下面是完整的代码示例： ```python import socket import select # 创建服务器端套接字 server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server_socket.bind(("localhost", 9999)) server_socket.listen(5) # 设置为非阻塞模式 server_socket.setblocking(False) print("Server started on port 9999") inputs = [server_socket] while True: readable, _, exceptional = select.select(inputs, [], inputs) for s in readable: if s is server_socket: # 如果是新连接请求 client_socket, addr = s.accept() print(f"New connection from {addr}") client_socket.setblocking(False) # 将客户端套接字设为非阻塞 inputs.append(client_socket) else: # 处理已有的客户端连接 try: data = s.recv(1024).decode('utf-8') if data: print(f"Received message from client: {data}") response = f"Echo: {data}" s.send(response.encode('utf-8')) else: # 客户端关闭连接 print(f"Client disconnected: {s.getpeername()}") inputs.remove(s) s.close() except ConnectionResetError: # 客户端强制断开 print(f"Client forcibly closed the connection: {s.getpeername()}") inputs.remove(s) s.close() # 执行本地逻辑（即使没有收到任何消息） print("Local output continues...") ``` #### 关键点说明 1. **非阻塞模式**：通过调用 `setblocking(False)` 方法使套接字进入非阻塞状态，从而允许主线程在没有输入的情况下继续运行[^1]。 2. **`select.select()` 函数**：用于监控多个文件描述符的状态变化。当有新的连接或者已有连接中有数据到达时，它会通知主循环进行处理[^1]。 3. **错误处理**：对于可能发生的异常情况（如客户端突然断开），进行了捕获和清理操作，防止整个服务崩溃[^1]。 此方案完全基于函数式编程风格完成，无需引入面向对象的设计理念。 --- ###