Flask断点续传需手动解析Range头、返回206状态码及Content-Range等响应头;多线程下载在Flask中易出错,应优先用Nginx或对象存储,而非自行实现。

Flask 中如何正确处理 Range 请求实现断点续传
Flask 本身不自动支持 Range 请求,必须手动解析 Range 头、计算字节偏移、返回 206 Partial Content 状态码,并设置 Content-Range 和 Accept-Ranges 响应头。漏掉任一环节,客户端(如 wget、curl、浏览器)就会当作普通下载重头开始。
常见错误现象:curl -H "Range: bytes=1000-2000" http://localhost:5000/file 返回 200 OK 全量内容,或直接 404 / 500;wget -c 提示 “continuing from 0” 而非实际偏移。
- 用
request.headers.get("Range")提取并解析,格式为"bytes=123-456",注意可能无-(如"bytes=123-"表示从 123 到末尾) - 文件必须以二进制模式打开(
open(path, "rb")),不能用send_file默认行为——它不支持分片 - 响应中必须显式写入
Content-Range(如"bytes 123-456/10000")、Content-Length(本次返回的字节数)、Accept-Ranges: bytes - 不要返回
Content-Encoding: gzip,压缩会破坏字节偏移对应关系
如何安全地在 Flask 路由中启动多线程下载任务
Flask 的默认开发服务器(Werkzeug)是单线程单进程,threading.Thread 启动后若主线程退出(如请求结束),子线程可能被强制终止;生产环境用 Gunicorn/Uvicorn 时,worker 进程模型更复杂,线程生命周期更难控制。
真正需要“多线程下载”的场景通常是:一个用户同时发起多个 Range 请求(如浏览器分片下载),或服务端需并发拉取上游资源再透传。前者靠客户端驱动,无需服务端开线程;后者才需谨慎管理线程。
- 避免在路由函数内直接
thread.start()并返回,除非你明确要“异步触发+轮询状态”,否则应同步处理当前请求 - 若必须后台拉取(例如代理下载远程大文件),用
concurrent.futures.ThreadPoolExecutor+submit(),并保存Future对象到全局字典或 Redis,供后续状态查询 - 切勿在线程里调用
flask.g或request对象——它们是线程局部的,子线程中为空 - 文件写入需加锁(
threading.Lock)或使用唯一临时文件名,防止多线程写同一文件导致损坏
为什么你不该在 Flask 里自己实现“多线程下载服务器”
HTTP 下载的并发能力主要取决于 Web 服务器层(Nginx、Gunicorn worker 数、系统 ulimit)和网络栈,不是靠 Python 层开更多 Thread 就能提升吞吐。盲目多线程反而引发 GIL 争抢、内存暴涨、文件描述符耗尽(OSError: [Errno 24] Too many open files)。
典型误用:for i in range(8): Thread(target=download_chunk, args=(url, start[i], end[i])).start() —— 这在 Flask 路由里几乎必然失败。
- 优先让 Nginx 处理静态文件(
sendfile零拷贝),比 Python 读写快一个数量级 - 需要动态生成或鉴权的文件,用流式响应(
Response(generate(), mimetype="application/octet-stream"))配合yield分块,比多线程更省内存 - 真有高并发下载需求,把文件托管到对象存储(S3、MinIO),用预签名 URL 直达,彻底绕过 Flask
一个可运行的断点续传最小示例(无多线程)
@app.route("/download/<filename>")
def download_file(filename):
file_path = os.path.join("/data", filename)
if not os.path.isfile(file_path):
return "Not found", 404
<pre class="brush:php;toolbar:false;">stat = os.stat(file_path)
file_size = stat.st_size
range_header = request.headers.get("Range")
if not range_header:
return send_file(file_path, as_attachment=True)
# 解析 Range: bytes=100-199
try:
byte_range = range_header.strip().replace("bytes=", "").split("-")
start = int(byte_range[0]) if byte_range[0] else 0
end = int(byte_range[1]) if byte_range[1] else file_size - 1
except (ValueError, IndexError):
return "Range Not Satisfiable", 416
if start >= file_size or end end:
return "Range Not Satisfiable", 416
length = end - start + 1
with open(file_path, "rb") as f:
f.seek(start)
data = f.read(length)
response = Response(data, status=206, mimetype="application/octet-stream")
response.headers["Content-Range"] = f"bytes {start}-{end}/{file_size}"
response.headers["Accept-Ranges"] = "bytes"
response.headers["Content-Length"] = str(length)
return response
这个例子没碰线程,但已满足标准断点续传。多线程的引入时机、边界和清理,远比看起来复杂——多数人卡在 Range 解析和响应头拼写错误上,而不是线程数配多少。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











