实现 TCP 双向通信的关键在于客户端和服务器端都能发送和接收数据。Python 提供了 `socket` 模块，可以用于创建 TCP 服务器和客户端，通过 `send()` 和 `recv()` 方法实现数据的发送与接收。 ### TCP 服务器端代码 以下是一个支持多个客户端连接的 TCP 服务器示例，使用多线程处理每个客户端的连接： ```python from socket import * import threading class TCPServer(threading.Thread): def __init__(self, addr, bufsize): threading.Thread.__init__(self) self.addr = addr self.bufsize = bufsize self.sock = socket(AF_INET, SOCK_STREAM) self.sock.bind(addr) self.sock.listen(5) def run(self): print("等待客户端连接...") while True: client_sock, client_addr = self.sock.accept() print(f"已连接客户端: {client_addr}") client_thread = threading.Thread(target=self.handle_client, args=(client_sock,)) client_thread.start() def handle_client(self, client_sock): while True: data = client_sock.recv(self.bufsize) if not data: break print(f"收到来自客户端的消息: {data.decode()}") response = input("请输入回复内容: ") client_sock.send(response.encode()) client_sock.close() # 启动服务器 server_addr = ("localhost", 12345) server = TCPServer(server_addr, 2048) server.start() ``` ### TCP 客户端代码 客户端代码负责连接到服务器，并能够发送和接收消息： ```python from socket import * # 客户端配置 server_addr = ("localhost", 12345) buffer_size = 2048 # 创建客户端套接字 client_socket = socket(AF_INET, SOCK_STREAM) client_socket.connect(server_addr) print("已连接到服务器") try: while True: # 发送消息到服务器 send_data = input("请输入要发送的内容: ") if not send_data: break client_socket.send(send_data.encode()) # 接收来自服务器的消息 recv_data = client_socket.recv(buffer_size) if not recv_data: break print(f"收到来自服务器的消息: {recv_data.decode()}") finally: client_socket.close() ``` ### 代码说明 1. **服务器端**： - 使用 `socket()` 创建 TCP 套接字。 - 调用 `bind()` 将套接字绑定到指定的地址和端口。 - 使用 `listen()` 开始监听客户端的连接请求。 - 通过 `accept()` 接收客户端的连接请求，并为每个客户端创建一个新的线程来处理通信。 - 在 `handle_client()` 函数中，服务器接收客户端发送的消息，并向客户端发送回复。 2. **客户端**： - 使用 `socket()` 创建 TCP 套接字。 - 调用 `connect()` 连接到服务器。 - 使用 `send()` 发送数据到服务器。 - 使用 `recv()` 接收服务器的回复。 ### 双向通信的实现 双向通信的实现依赖于客户端和服务器都能够在发送数据后等待接收对方的回复。在上述代码中，客户端和服务器都可以通过 `send()` 发送数据，并通过 `recv()` 接收对方发送的数据。这种交互方式允许双方在任意时刻发送和接收数据，从而实现双向通信。 ### 注意事项 - **线程安全**：由于服务器使用了多线程处理多个客户端连接，因此需要确保线程安全。在实际应用中，可能需要使用锁机制来避免多个线程同时访问共享资源。 - **异常处理**：在实际应用中，建议添加异常处理机制，以应对网络中断或其他错误情况。 - **关闭连接**：在通信结束时，确保正确关闭套接字，以释放资源。 通过上述代码，可以在 Python 中实现 TCP 双向通信，适用于简单的聊天应用或数据交换场景。