Python 通过 UDP 发送与接收超过 64KB 的数据包

UDP 协议限制与分包原理

标准以太网环境下的最大传输单元（MTU）通常为 1500 字节，而 UDP 头部包含 16 位长度字段，其理论最大值为 65535 字节（扣除 8 字节协议头后有效载荷约 65527 字节）。当业务需要传递的文件或消息体超过此阈值时，操作系统会直接丢弃 oversized 报文或在底层触发 IP 分片，导致丢包率骤升。因此，必须在应用层实施显式的 大数据包分割 策略：先约定总大小，再将原始字节流划分为多个小于 MTU 或缓冲区容量的小块依次发出。

第1步：客户端切割数据并封装发送头

客户端负责将目标数据按预设阈值切分为定长块。为保证接收端能准确判断何时停止拼接，发送序列的第一帧需携带纯文本格式的数据总长度。后续各帧直接透传原始字节切片。该入口对应 socket.sendto() 方法，参数需指定目标主机地址与端口。

import socket

def send_large_data(sock, data):
    # 首先发送数据的大小，以便服务器知道要接收多少数据
    sock.sendto(str(len(data)).encode(), ('localhost', 12345))
    
    # 然后将数据分成小块并发送
    chunk_size = 4096  # 可根据需要调整这个大小
    for i in range(0, len(data), chunk_size):
        sock.sendto(data[i:i+chunk_size], ('localhost', 12345))

def start_client():
    client_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
    # 创建一个大于64KB的数据包作为示例
    large_data = b'x' * 70000  # 70,000 字节的数据
    
    send_large_data(client_sock, large_data)

if __name__ == "__main__":
    start_client()

第2步：服务端解析长度并逐包接收重组

服务端启动后绑定监听地址与端口。首先进入无限循环等待连接，首次调用 recvfrom() 获取长度字符串并转为整数，随后根据剩余需接收字节数动态缩减接收缓冲区尺寸。通过 while 条件持续追加直到完成组装。重要参数为预期总大小与实际已累积长度，可观察的完成状态为接收到的数据字节数严格等于初始宣告值。

import socket

def receive_large_data(sock, expected_size):
    data = b''
    while len(data) < expected_size:
        remaining = expected_size - len(data)
        packet = sock.recv(min(remaining, 4096))  # 使用较小的缓冲区大小以模拟实际情况
        if not packet:
            raise Exception("Connection closed by remote host")
        data += packet
    return data

def start_server():
    server_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    server_sock.bind(('localhost', 12345))
    
    while True:
        data, addr = server_sock.recvfrom(1024)  # 接收数据包，包含数据大小和实际数据的第一部分
        total_size = int(data.decode())
        print(f"Expecting {total_size} bytes of data from {addr}")
        
        large_data = receive_large_data(server_sock, total_size)
        print(f"Received {len(large_data)} bytes of data from {addr}")
        
        # 处理数据...
        # 例如，可以将其写入文件或进行其他处理

if __name__ == "__main__":
    start_server()

核心参数配置与运行验证

上述流程依赖 chunk_size 与接收缓冲区阈值的匹配。示例中统一采用 4096 字节作为切分粒度，既避开常见路由器的 MTU 瓶颈，又减少上下文切换开销。验证运行时需先启动服务端脚本，终端输出显示等待字节数；随后运行客户端，两行 Print 语句分别打印预期体积与最终接收体积，数值一致即表示重组成功。建议在实际局域网或公网测试时，替换 'localhost' 为对应网卡 IP 段，并确保防火墙放行 12345 端口的 UDP 流量。

生产环境部署注意事项

• 本示例未引入序列号与校验和机制。由于 UDP 本质无序，极端网络抖动可能导致分片乱序抵达，引发重组错位。高可用场景应在每块载荷头部追加 4 字节序号字段，服务端改用哈希表收集后排序重排。
• 示例仅做本地回环教学演示，未覆盖超时重试、连接断开异常捕获与粘包防护。生产部署请结合 time.sleep() 心跳检测、自定义 CRC32 校验或迁移至 TCP/QUIC 协议栈。
• 若传输目标含敏感内容，需在外层包裹 TLS/DTLS 或自行实现 AES-GCM 加密，否则裸奔的 UDP 切片极易被中间节点嗅探或篡改。

以上就是通过 Python 发送和接收超过 64KB UDP 数据包的详细内容，更多关于 Python 网络编程与 Socket 通信的资料请关注本站其它相关文章！