### 实现基于TCP协议的自定义通信规约 在实现基于TCP协议的自定义通信规约时，需要设计数据的格式、解析规则以及服务器和客户端的交互逻辑。自定义规约通常包括数据的头部、负载以及校验部分，以确保通信的可靠性和一致性。Python 提供了强大的网络编程能力，可以通过 `socket` 模块和多线程支持来实现这一目标。 #### 数据格式设计 自定义规约的数据格式通常包含以下几个部分： 1. **头部（Header）**：用于标识数据的长度、类型或其他元信息。 2. **负载（Payload）**：实际传输的数据内容。 3. **校验（Checksum）**：用于数据完整性校验，例如 CRC 校验。 例如，可以设计一个以冒号 `:` 分隔的文本协议，数据可能包含头部位置、旋转和面部参数等信息，格式如下： ``` <type>:<length>:<payload>:<checksum> ``` #### 服务器端实现 服务器端需要监听客户端的连接请求，并为每个连接创建独立的线程处理数据的接收、解析和响应。以下是实现的一个示例： ```python import socket import threading import hashlib # 处理客户端通信的线程类 class ClientHandler(threading.Thread): def __init__(self, client_socket, client_address): super().__init__() self.client_socket = client_socket self.client_address = client_address def run(self): print(f"新客户端连接: {self.client_address}") while True: try: data = self.client_socket.recv(1024) if not data: break # 解析数据 message = data.decode().strip() parts = message.split(":") if len(parts) != 4: print("数据格式错误") continue msg_type, length, payload, checksum = parts # 校验数据长度 if len(payload) != int(length): print("数据长度不匹配") continue # 校验数据完整性 calculated_checksum = hashlib.md5(payload.encode()).hexdigest() if calculated_checksum != checksum: print("数据校验失败") continue # 处理数据 print(f"从 {self.client_address} 收到数据: {payload}") # 回传响应 response = f"RESPONSE:{payload}" self.client_socket.sendall(response.encode()) except Exception as e: print(f"发生错误: {e}") break print(f"客户端 {self.client_address} 断开连接") self.client_socket.close() # TCP服务器类 class TCPServer: def __init__(self, host='0.0.0.0', port=1755): self.host = host self.port = port self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) def start(self): self.server_socket.bind((self.host, self.port)) self.server_socket.listen(5) print(f"服务器正在监听 {self.host}:{self.port}") while True: client_socket, client_address = self.server_socket.accept() handler = ClientHandler(client_socket, client_address) handler.start() if __name__ == "__main__": server = TCPServer() server.start() ``` #### 客户端实现 客户端需要按照自定义规约的格式发送数据，并接收服务器的响应。以下是客户端的示例代码： ```python import socket import hashlib def send_message(host='127.0.0.1', port=1755, msg_type="DATA", payload="Hello, World!"): # 计算校验值 checksum = hashlib.md5(payload.encode()).hexdigest() # 构造数据 length = len(payload) message = f"{msg_type}:{length}:{payload}:{checksum}" # 发送数据 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s: s.connect((host, port)) s.sendall(message.encode()) response = s.recv(1024) print(f"收到响应: {response.decode()}") if __name__ == "__main__": send_message() ``` #### 规约扩展 1. **支持CRC校验码生成**：可以在数据传输中加入 CRC 校验，以提高数据完整性的验证能力。Python 提供了 `crcmod` 库用于生成 CRC 校验码。 2. **动态命令处理**：服务器端可以根据数据类型执行不同的操作，例如执行特定的命令或调用特定的业务逻辑。 3. **日志记录**：在服务器端添加日志记录功能，以便跟踪客户端的请求和服务器的响应。 ###