Python通过UDP传输超过64k的信息_开发_开发者

开发者 https://www.devze.com 2024-08-17 09:17 出处：网络作者： Tech

在UDP中，单个数据包的最大尺寸通常受到网络层的限制，这通常被称为最大传输单元（MTU）。在以太网环境中，标准的MTU大小通常为1500字节。尽管有些网络环境可能支持更大的数据包，但是UDP数据包的理论最大限制是6553

在UDP中，单个数据包的最大尺寸通常受到网络层的限制，这通常被称为最大传输单元（MTU）。在以太网环境中，标准的MTU大小通常为1500字节。尽管有些网络环境可能支持更大的数据包，但是UDP数据包的理论最大限制是65535字节（64KB），这是由于UDP头部的16位长度字段决定的。

然而，如果你需要发送超过这个限制的数据，你必须将数据分割成多个较小的数据包，并在接收端重新组装它们。下面是一个python示例，展示了如何通过UDP发送和接收超过64KB的数据。

服务器端（接收端）代码：

import socket  
  
def receive_large_data(sock, expected_size):  
    data = b''  
    while len(data) < expected_size:  
        remaining = expe编程客栈cted_size - len(data)  
        packet = sock.recv(min(rjavascriptemaining, 4096))  # 使用较小的缓冲区大小以模拟实际情况  
        if not packet:  
            raise Exception("Connection closed by remote host")  
        data += packet  
    return data  
  
def start_serjavascriptver():  
    server_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRpythonAM)  
    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()

客户端（发送端）代码：

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()

注意：