### 协议解析函数 协议处理模块应包含用于解析接收到的数据帧的函数。该函数负责校验数据完整性、提取关键字段（如命令类型、数据长度、数据内容等），并返回结构化的数据格式。例如，CRC 校验函数可用于验证数据是否在传输过程中发生错误[^1]。 ```python def parse_frame(data): # 假设帧格式为：[命令][长度][数据][CRC] if len(data) < 4: return None # 数据长度不足，丢弃 command = data[0] length = data[1] payload = data[2:2+length] received_crc = data[2+length:] # CRC 校验 crc_calculator = crcmod.predefined.Crc('crc-16') crc_calculator.update(data[:-2]) calculated_crc = crc_calculator.digest() if received_crc != calculated_crc: return None # CRC 校验失败，丢弃数据 return {'command': command, 'payload': payload} ``` ### 数据打包函数 用于将上位机的指令和数据按照协议格式打包成完整数据帧，包括命令、数据长度、数据内容和 CRC 校验码。该函数确保发送的数据符合协议规范，以便下位机能够正确识别并处理。 ```python def pack_frame(command, payload): length = len(payload) frame = bytes([command, length]) + payload crc_calculator = crcmod.predefined.Crc('crc-16') crc_calculator.update(frame) crc_value = crc_calculator.digest() return frame + crc_value ``` ### 连接管理函数 负责建立和维护 TCP 连接，包括客户端连接、服务器端监听、数据收发和异常处理。可使用 `socket` 模块实现连接的建立与数据的传输，并通过线程或异步机制处理并发通信[^3]。 ```python def handle_connection(sock, addr): print(f'新连接来自 {addr}') try: while True: data = sock.recv(1024) if not data: break parsed_data = parse_frame(data) if parsed_data: print(f'接收到命令: {parsed_data["command"]}, 数据: {parsed_data["payload"]}') # 发送响应 response = pack_frame(0x01, b'ACK') sock.sendall(response) finally: sock.close() print(f'连接 {addr} 已关闭') ``` ### 异常处理与重连机制 为了确保通信的稳定性，模块应包含异常处理逻辑，包括连接中断后的自动重连、数据接收超时处理、CRC 校验失败重传等机制。该部分可结合 `try-except` 语句和定时器实现[^2]。 ```python def reconnect(): while True: try: sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.connect(('192.168.1.100', 5000)) print('连接成功') return sock except socket.error as e: print(f'连接失败: {e}, 5秒后重试...') time.sleep(5) ``` ### 协议扩展与自定义字段支持 为了适应不同设备的通信需求，模块应支持协议的扩展性设计，例如允许用户自定义帧格式、添加额外的字段（如设备 ID、时间戳等），并提供灵活的配置接口。这种设计可提高模块的通用性，使其适用于多种上下位机通信场景[^4]。 ---