TCP客户端接收SCD30传感器数据时字节长度不稳定问题

问题根源 #

TCP是流式传输协议，数据以连续字节流形式传递，没有天然的数据包边界：

• 单次recv只能获取当前缓冲区中的部分数据，出现只收到1-2字节的情况
• 传感器可能连续发送多次响应，导致数据粘包，出现收到12字节重复数据的情况

你的代码仅调用了一次recv，无法适配TCP的流式特性，因此会出现响应长度不稳定的问题。

解决方案 #

1. 循环接收完整数据 #

已知正确响应长度为7字节，循环调用recv累加数据，直到获取到完整的7字节：

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as tcp:
    try:
        tcp.settimeout(self.timeout)
        tcp.connect((self.ip, self.port))
        tcp.settimeout(5)  # 设置合理超时，避免无限等待
        tcp.sendall(b"\x61\x03\x00\x20\x00\x01\x8c\x60")
        
        expected_len = 7
        data = b""
        while len(data) < expected_len:
            # 每次接收剩余所需长度的数据
            chunk = tcp.recv(expected_len - len(data))
            if not chunk:
                raise ConnectionError("连接中断，未收到完整数据")
            data += chunk
        
        print(f"完整响应：{data}")
    except Exception as e:
        print(f"错误：{e}")

2. 处理粘包场景 #

如果出现粘包（比如收到包含两次响应的12字节数据），需要缓存多余字节供下一次读取使用：

# 类/全局级别缓存，存储粘包剩余数据
packet_buffer = b""

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as tcp:
    try:
        tcp.settimeout(self.timeout)
        tcp.connect((self.ip, self.port))
        tcp.settimeout(5)
        tcp.sendall(b"\x61\x03\x00\x20\x00\x01\x8c\x60")
        
        expected_len = 7
        data = packet_buffer  # 先读取缓存中的遗留数据
        while len(data) < expected_len:
            chunk = tcp.recv(1024)  # 每次接收较大缓冲区，提高效率
            if not chunk:
                raise ConnectionError("连接中断，未收到完整数据")
            data += chunk
        
        # 提取完整响应，剩余数据存入缓存
        valid_response = data[:expected_len]
        packet_buffer = data[expected_len:]
        
        print(f"完整响应：{valid_response}")
        if packet_buffer:
            print(f"缓存粘包数据：{packet_buffer}")
    except Exception as e:
        print(f"错误：{e}")

3. 额外验证建议 #

除了长度校验，还可以检查响应的起始标识（比如是否以b'a\x03'开头），确保收到的是目标指令的正确响应，避免处理无效数据。

内容的提问来源于stack exchange，提问作者Microscoop