### 如何用Python编写多线程Socket服务器 #### 创建多线程TCP服务器 为了创建一个多线程的TCP服务器，可以利用`socketserver`模块中的`ThreadingMixIn`类来扩展标准的TCP服务器。这使得每次有新的连接请求到达时都会启动一个新的线程处理该请求。 ```python from socketserver import ThreadingTCPServer, StreamRequestHandler import threading class MyStreamRequestHandler(StreamRequestHandler): def handle(self): while True: try: data = self.rfile.readline().strip() if not data: break print(f"Received from {self.client_address}:{data.decode('utf-8')}") response = f"ECHO: {data.decode('utf-8')}" self.wfile.write(response.encode('utf-8')) except Exception as e: print(e) break if __name__ == "__main__": HOST, PORT = "", 9999 with ThreadingTCPServer((HOST, PORT), MyStreamRequestHandler) as server: ip, port = server.server_address # Start a thread with the server -- that thread will then start one # more thread for each request server_thread = threading.Thread(target=server.serve_forever) # Exit the server thread when the main thread terminates server_thread.daemon = True server_thread.start() print(f"Serving on {ip}:{port}") # Keep the main thread alive until interrupted by user or error. try: while True: pass except KeyboardInterrupt: print("\nShutting down gracefully.") server.shutdown() ``` 这段代码定义了一个简单的回显服务器[^2]，它接收来自客户端的消息并将其转换为大写形式返回给发送者。每当有一个新连接到来时，就会创建一个新的线程去处理这个特定客户的会话而不阻塞其他可能正在等待的服务请求。 对于更复杂的场景，比如需要共享资源或者同步操作，则应该考虑引入锁机制或者其他高级特性如队列等工具来确保数据的一致性和安全性[^3]。