### Python 流式套接字示例代码 #### TCP服务器端代码 下面展示了如何创建一个简单的TCP服务器，该服务器能够接收来自客户端的消息并作出响应。 ```python from socket import * # 创建TCP/IP套接字 sockfd = socket(AF_INET, SOCK_STREAM) try: # 绑定地址到套接字 sockfd.bind(('127.0.0.1', 8888)) # 开始监听传入连接 sockfd.listen(5) print('Waiting for connection...') while True: # 接受一个新的连接 connfd, addr = sockfd.accept() print(f'Connected by {addr}') try: while True: # 接收数据 data = connfd.recv(1024).decode() if not data or data.lower().strip() == 'exit': break print(f'Received message: "{data}"') # 向客户端发送回复 response = f'Echo: {data}' sent_bytes = connfd.send(response.encode()) print(f'Sent back {sent_bytes} bytes of echo.') finally: # 清理连接 connfd.close() finally: # 关闭服务器套接字 sockfd.close() ``` 这段代码实现了基本的TCP服务器功能，包括建立连接、处理请求以及断开连接[^2]。 #### 客户端代码片段 对于想要与上述服务器交互的简单TCP客户端来说，则可以通过如下方式实现： ```python import socket def tcp_client(): ADDR = ('127.0.0.1', 8888) with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as client_socket: client_socket.connect(ADDR) while True: msg = input("Input your message:") if msg.strip().lower() == 'exit': break client_socket.sendall(msg.encode()) recv_data = client_socket.recv(1024).decode() print(f'Server replied: {recv_data}') if __name__ == '__main__': tcp_client() ``` 这里定义了一个`tcp_client()`函数用于向指定地址发起TCP连接，并持续地向服务器发送消息直到用户输入退出命令为止。每次收到服务器回应后都会将其打印出来。