在 Python 中实现一个 TCP 服务器可以通过标准库 `socket` 来完成。该库提供了底层网络通信接口，支持创建 TCP 和 UDP 套接字。以下是一个完整的 TCP 服务器示例，它接收客户端连接，读取客户端发送的数据，并将数据回显给客户端。 ### 简单的 TCP 服务器实现 以下是一个基本的 TCP 服务器脚本，它监听本地的指定端口，接受客户端连接，并回显客户端发送的消息： ```python import socket # 配置服务器参数 HOST = '127.0.0.1' # 本地回环地址 PORT = 65432 # 使用非特权端口 # 创建 TCP 服务器套接字 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: s.bind((HOST, PORT)) # 绑定地址和端口 s.listen() # 开始监听连接 print(f"Server is listening on {HOST}:{PORT}") # 接受客户端连接 conn, addr = s.accept() with conn: print(f"Connected by {addr}") while True: data = conn.recv(1024) # 接收客户端数据 if not data: break print(f"Received data: {data.decode()}") conn.sendall(data) # 将数据原样返回给客户端 ``` ### 客户端测试脚本 为了测试上述 TCP 服务器，可以使用以下客户端代码： ```python import socket HOST = '127.0.0.1' PORT = 65432 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: s.connect((HOST, PORT)) # 连接到服务器 s.sendall(b'Hello, TCP Server!') # 发送数据 data = s.recv(1024) # 接收回显数据 print(f"Received from server: {data.decode()}") ``` ### 使用 `ThreadingMixIn` 实现多线程 TCP 服务器 如果希望服务器能够同时处理多个客户端连接，可以使用 `ThreadingMixIn` 来实现多线程处理： ```python import socketserver class ThreadedTCPRequestHandler(socketserver.BaseRequestHandler): def handle(self): while True: data = self.request.recv(1024) if not data: break print(f"Received from {self.client_address}: {data.decode()}") self.request.sendall(data) # 回显数据 class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer): pass if __name__ == "__main__": HOST, PORT = "127.0.0.1", 65432 with ThreadedTCPServer((HOST, PORT), ThreadedTCPRequestHandler) as server: print(f"Multi-threaded TCP Server is running on {HOST}:{PORT}") server.serve_forever() ``` ### 使用 `asyncio` 实现异步 TCP 服务器 对于高并发场景，可以使用 `asyncio` 模块来构建异步 TCP 服务器[^1]： ```python import asyncio class EchoServerProtocol(asyncio.Protocol): def connection_made(self, transport): self.transport = transport print("Client connected") def data_received(self, data): print(f"Received: {data.decode()}") self.transport.write(data) # 回显数据 async def main(): loop = asyncio.get_running_loop() server = await loop.create_server( lambda: EchoServerProtocol(), '127.0.0.1', 65432 ) async with server: await server.serve_forever() asyncio.run(main()) ``` 以上示例展示了不同方式实现的 TCP 服务器，适用于不同场景下的需求。可以根据具体应用场景选择同步、多线程或异步模型。