通过Socket传输MP4文件时接收不完整问题的解决方案-Python教程-PHP中文网

通过Socket传输MP4文件时接收不完整问题的解决方案

花韻仙語

发布： 2025-10-04 13:50:24

原创

177人浏览过

通过socket传输mp4文件时接收不完整问题的解决方案

本文旨在解决在使用Python Socket进行MP4文件传输时，接收端接收到的文件不完整的问题。通过分析常见错误原因，提供修正后的代码示例，并强调在使用recv()函数时正确处理接收到的数据长度的重要性，确保文件传输的完整性和可靠性。

在使用Socket进行文件传输时，尤其是MP4等较大的二进制文件，经常会遇到接收端接收到的数据不完整的情况。这通常不是Socket本身的问题，而是由于对recv()函数的理解和使用不当造成的。recv()函数的作用是从Socket接收数据，但它并不保证每次调用都返回指定大小的数据块。它返回的是实际接收到的数据长度，这个长度可能小于你请求的长度。

问题分析

原始代码中，客户端（接收端）的代码存在一个关键问题：

while read < data_len:
    f.write(soc.recv(4096))
    read += 4096

登录后复制

这段代码盲目地假设soc.recv(4096)每次都会返回4096字节的数据。然而，recv()函数只保证返回最多 4096字节的数据，实际返回的数据长度可能小于这个值。因此，read变量的增加值与实际接收到的数据长度不一致，导致循环提前结束，最终写入文件的内容不完整。

解决方案

正确的做法是每次循环都检查recv()函数实际返回的数据长度，并将其加到read变量上。同时，需要处理连接断开的情况，即recv()返回空字节串（b''）时，表示对端已经关闭连接，应该立即退出循环。

小文AI论文

轻松解决论文写作难题，AI论文助您一键完成，仅需一杯咖啡时间，即可轻松问鼎学术高峰！

查看详情

以下是修正后的客户端代码：

import socket

if __name__ == '__main__':
    soc = socket.socket()
    soc.connect(('6.tcp.eu.ngrok.io', 19717))  # 替换为实际的ngrok地址
    data_len = int(soc.recv(16).decode())
    with open('new.mp4', 'wb') as f:
        read = 0
        while read < data_len:
            data = soc.recv(4096)
            if not data:
                break  # 对端关闭连接
            read += len(data)
            f.write(data)
    print(f"已接收 {read} 字节, 预期 {data_len} 字节") # 打印接收到的字节数，方便调试

登录后复制

代码解释：

data = soc.recv(4096): 从socket接收数据，最多接收4096字节。
if not data:: 检查data是否为空。如果为空，表示连接已关闭，跳出循环。
read += len(data): 将实际接收到的数据长度加到read变量上。
f.write(data): 将接收到的数据写入文件。
print(f"已接收 {read} 字节, 预期 {data_len} 字节"): 打印实际接收到的字节数，方便调试。

服务器端代码（发送端）

服务器端代码基本没有问题，但为了保证最佳实践，可以加入一些错误处理机制。

import socket

if __name__ == '__main__':
    with open('vid.mp4', 'rb') as f:
        data = f.read()
    server_soc = socket.socket()
    server_soc.bind(('localhost', 1234))
    server_soc.listen()
    client_soc, addr = server_soc.accept()
    print(f"连接来自：{addr}") # 打印客户端地址
    try:
        data_len = len(data)
        client_soc.send(str(data_len).rjust(16, '0').encode())
        client_soc.sendall(data)
        print(f"已发送 {data_len} 字节") # 打印已发送的字节数
    except Exception as e:
        print(f"发送数据时发生错误：{e}")
    finally:
        client_soc.close()
        server_soc.close()

登录后复制

注意事项和总结