大文件分块上传的代码，C++转python，由python实现。

目录

原文章地址：

Python 实现的大致框架

所实现的代码

原文章地址：

https://bobowen.blog.csdn.net/article/details/135040356?spm=1001.2014.3001.5502

????????要使用 Python 实现上述 C++ 代码的功能，我们将需要一系列的库，例如 requests 用于 HTTP 请求，threading 用于多线程处理，以及 Python 的标准库函数用于文件处理和同步。

Python 实现的大致框架

1. 文件分块（FileChunker） - 读取文件并分成多个块。
2. HTTP请求处理（HttpWrapper） - 创建 HTTP 会话和发送请求。
3. 块上传（ChunkUploader） - 上传文件的特定块。
4. 上传队列和管理（UploadQueue & UploadManager） - 管理上传队列和多线程上传。

先安装必要的库：

pip install requests

所实现的代码

import requests
import threading
from queue import Queue

# 文件分块
def split_file_into_chunks(file_path, chunk_size=10*1024*1024):
    with open(file_path, 'rb') as file:
        while True:
            chunk = file.read(chunk_size)
            if not chunk:
                break
            yield chunk

# 块上传
class ChunkUploader:
    @staticmethod
    def upload_chunk(url, chunk, chunk_number, retries=3):
        headers = {'Content-Type': 'application/octet-stream', 'Chunk-Number': str(chunk_number)}
        for attempt in range(retries):
            try:
                response = requests.post(url, headers=headers, data=chunk)
                response.raise_for_status()
                return response
            except requests.RequestException as e:
                if attempt < retries - 1:
                    continue
                raise

# 上传队列和管理
class UploadManager:
    def __init__(self, url, chunks):
        self.url = url
        self.chunks = chunks
        self.queue = Queue()
        self.uploaded_chunks = [False] * len(chunks)
        self.lock = threading.Lock()

    def start_upload(self, max_threads=4):
        for chunk_number, chunk in enumerate(self.chunks):
            self.queue.put((chunk, chunk_number))

        threads = []
        for _ in range(max_threads):
            thread = threading.Thread(target=self.upload_thread)
            thread.start()
            threads.append(thread)

        for thread in threads:
            thread.join()

    def upload_thread(self):
        while not self.queue.empty():
            chunk, chunk_number = self.queue.get()
            try:
                ChunkUploader.upload_chunk(self.url, chunk, chunk_number)
                with self.lock:
                    self.uploaded_chunks[chunk_number] = True
                    print(f"Chunk {chunk_number} uploaded successfully")
            except Exception as e:
                print(f"Error uploading chunk {chunk_number}: {e}")

# 使用示例
if __name__ == "__main__":
    file_path = "path/to/your/largefile"
    url = "https://www.example.com/upload"
    chunks = list(split_file_into_chunks(file_path))

    manager = UploadManager(url, chunks)
    manager.start_upload()