大文件上传导致文件损坏

大文件上传可能会导致文件损坏的一个常见原因是在上传过程中出现了网络中断或上传超时的情况。为了解决这个问题，可以使用以下几种方法：

1. 使用断点续传技术：

   • 在客户端进行文件分块，每个块的大小可以根据实际情况进行调整。
   • 上传每个块时，记录已上传的块的索引或偏移量。
   • 当上传中断时，下次重新上传时，只需上传未上传的块，而不是整个文件。
   • 服务器端接收到每个块后，根据块的索引或偏移量，将每个块存储到正确的位置。

   示例代码：

   客户端代码：

   import requests
   
   def upload_file_chunk(file_path, chunk_index, chunk_size):
       with open(file_path, 'rb') as file:
           file.seek(chunk_index * chunk_size)
           chunk_data = file.read(chunk_size)
           # 使用 POST 请求上传块数据
           response = requests.post('http://example.com/upload', data=chunk_data)
           if response.status_code == 200:
               print(f'Chunk {chunk_index} uploaded successfully')
           else:
               print(f'Chunk {chunk_index} upload failed')
   
   def upload_large_file(file_path, chunk_size):
       with open(file_path, 'rb') as file:
           file_size = len(file.read())
           num_chunks = (file_size // chunk_size) + 1
   
       for i in range(num_chunks):
           upload_file_chunk(file_path, i, chunk_size)
   

   服务器端代码：

   from flask import Flask, request
   
   app = Flask(__name__)
   
   @app.route('/upload', methods=['POST'])
   def upload():
       chunk_data = request.data
       # 处理上传的块数据
       # ...
   
   if __name__ == '__main__':
       app.run()
   

2. 使用文件校验和：

   • 在客户端上传文件之前，计算文件的校验和（如MD5、SHA1等）。
   • 在上传完成后，服务器端计算接收到的文件的校验和。
   • 比较两个校验和是否相等，如果不相等，则说明文件有损坏。

   示例代码：

   客户端代码：

   import hashlib
   import requests
   
   def calculate_checksum(file_path):
       with open(file_path, 'rb') as file:
           checksum = hashlib.md5()
           while chunk := file.read(8192):
               checksum.update(chunk)
       return checksum.hexdigest()
   
   def upload_file(file_path):
       checksum = calculate_checksum(file_path)
       with open(file_path, 'rb') as file:
           # 使用 POST 请求上传文件数据
           response = requests.post('http://example.com/upload', data=file.read())
           if response.status_code == 200:
               server_checksum = response.headers['Checksum']
               if checksum == server_checksum:
                   print('File uploaded successfully')
               else:
                   print('File upload failed: checksum mismatch')
           else:
               print('File upload failed')
   
   

   服务器端代码：

   from flask import Flask, request
   import hashlib
   
   app = Flask(__name__)
   
   @app.route('/upload', methods=['POST'])
   def upload():
       file_data = request.data
       # 处理上传的文件数据
       # ...
   
       # 计算文件的校验和
       checksum = hashlib.md5()
       checksum.update(file_data)
       file_checksum = checksum.hexdigest()
   
       # 返回校验和
       return '', 200, {'Checksum': file_checksum}
   
   if __name__ == '__main__':
       app.run()
   

这些方法可以帮助解决大文件上传导致文件损坏的问题，但仍然需要根据具体情况进行适当的调整和优化。