promise本身不直接提供并发控制或顺序合并能力,但配合promise.all、async/await及队列逻辑,可在网盘分片上传中实现可控并发与按序合并:先切片并标记index,再用并发队列上传并按index排序结果,最后按原始顺序发起合并请求。

Promise 本身不直接提供并发控制或顺序合并能力,但配合 Promise.all、Promise.allSettled、async/await 和简单的队列逻辑,就能在网盘大文件分片上传中实现可控并发 + 按序合并。
分片上传前:切片与元信息准备
大文件需预先按固定大小(如 4MB)切片,生成唯一标识(如 fileId + index),并记录总片数、每片偏移量、Hash(可选校验)。这些信息用于后续上传与合并请求:
- 前端用
File.slice()或Blob.slice()获取每个分片 Blob - 为每片生成独立 Promise(封装为上传函数),但先不立即执行
- 保留分片索引(
index),这是后续排序和合并的关键依据
并发控制:用 Promise 队列限制同时请求数
直接 Promise.all(chunks.map(upload)) 会一次性发起所有请求,易触发浏览器连接数限制或服务端限流。应控制并发数(如 3~5 个):
一种轻量做法是手写串行+并发混合队列:
async function uploadWithConcurrency(chunks, max = 3) {
const results = [];
const queue = [...chunks];
<p>async function run() {
while (queue.length > 0) {
const chunk = queue.shift();
try {
const res = await uploadSingle(chunk); // 返回 { index, etag, ... }
results.push(res);
} catch (err) {
results.push({ index: chunk.index, error: err.message });
}
}
}</p><p>// 启动 max 个并发任务
await Promise.all(Array(max).fill().map(run));
return results.sort((a, b) => a.index - b.index); // 强制按序排列
}</p>
更健壮的方式可用 p-limit 库或基于 async-pool 封装,核心是:每个 Promise 必须 resolve 带有 index 的结果,便于后续归位。
Java项目代码review工具。分析Git变更+完整调用链路上下文,推断业务需求,进行多维度评分和分类汇总,生成完整PRD文档。包含细粒度Java代码审查清单(Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
顺序合并:等所有分片上传完成再发合并请求
合并不是“按上传完成顺序”,而是“按分片原始顺序”提交服务端。因此客户端必须确保:
- 所有分片上传成功(或失败重试后成功),且结果数组按
index升序排列 - 合并请求体包含有序的分片标识列表(如
[{"etag":"abc","index":0}, {"etag":"def","index":1}]) - 调用合并接口(如
POST /api/merge)时,传入文件 ID、总片数、有序分片信息
示例合并逻辑:
const mergedResult = await uploadWithConcurrency(chunks, 4);
if (mergedResult.some(r => r.error)) {
throw new Error('部分分片上传失败');
}
<p>// 确保已按 index 排序
const sortedParts = mergedResult.map(r => ({ etag: r.etag, index: r.index }))
.sort((a, b) => a.index - b.index);</p><p>await fetch('/api/merge', {
method: 'POST',
body: JSON.stringify({
fileId: 'xxx',
total: chunks.length,
parts: sortedParts
})
});</p>
补充:失败重试与断点续传
真实场景需增强鲁棒性:
- 单片失败时,只重试该片(用
index定位),不中断整个队列 - 上传前检查服务端是否已存在该分片(通过 Hash 或 ETag),跳过已传成功的片
- 将已上传的
index列表存入 localStorage 或 IndexedDB,页面刷新后可恢复上传 - 合并失败时,不应重复上传全部分片,而应查服务端状态,仅补传缺失片
这些逻辑都依赖每个分片的 index 和唯一标识,Promise 只是承载异步操作的容器,关键在于结构化数据流与状态管理。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










